스파크 스트리밍에서 연결이 끊어졌습니다.

Question

저는 현재 아파치 스파크 스트리밍으로 작업하고 있습니다. 스트리밍을 중지하고 데이터 소스에 다시 연결하기 위해 외부 데이터 소스와 연결이 끊어 졌는지 여부를 감지하는 방법을 알고 싶습니다. 어떤 도움

Answer 1

에 미리

덕분에 당신이 가지고있는 수신기에 리스너를 추가하고 수신기가 정지했을 때 스트리밍 컨텍스트를 중지합니다.

예 :

streamContext.addStreamingListener(new StreamingListener() { 

     @Override 
     public void onReceiverStopped(StreamingListenerReceiverStopped arg0) { 
      streamContext.stop(true, true); 
     } 
}