檢測火花流中丟失的連接

Question

我目前正在使用apache spark流。我想知道如何檢測連接是否與外部數據源丟失，以便我們可以停止流式傳輸並重新連接到數據源。

預先感謝任何幫助

Answer 1

添加一個監聽器，你有接收器，當接收器已經停止停止流上下文。

例如：

streamContext.addStreamingListener(new StreamingListener() { 

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