如何停止Spark Streaming

Question

5

我正在处理 Twitter 连接器。我想在一分钟后停止流式传输。有谁能给出如何做到这一点的建议吗？我尝试了 ssc.awaitTermination(60000)，但它没有起作用。

- Sadaf

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- mattinbits · Accepted Answer

请注意，带有超时的 awaitTermination 已经被弃用： https://github.com/apache/spark/blob/master/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala#L633 然而，在使用 awaitTermination 或 awaitTerminationOrTimeout 时，您应该在超时后调用 ssc.stop 来停止上下文。