如何停止火花流

Question

我正在使用Twitter连接器。我想在一分钟后停止直播。谁能为此做个主意？我尝试了ssc.awaitTermination（60000）。但这没用。

Answer 1

请注意，awaitTermination不推荐使用超时：

https://github.com/apache/spark/blob/master/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala#L633

但是，无论使用awaitTerminationor ，awaitTerminationOrTimeout您都应该ssc.stop在达到超时后停止上下文。