检测火花流中丢失的连接

Question

我目前正在使用apache spark流。我想知道如何检测连接是否与外部数据源丢失，以便我们可以停止流式传输并重新连接到数据源。

预先感谢任何帮助

Answer 1

添加一个监听器，你有接收器，当接收器已经停止停止流上下文。

例如：

streamContext.addStreamingListener(new StreamingListener() { 

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