apache-spark - Spark StreamingContext awaitTerminationOrTimeout

Question

我打电话 streamingContext.awaitTerminationOrTimeout(timeout) ，但我想制作 timeout环境依赖。

这意味着如果我的环境是 UAT，我想停止我的工作，但如果我的环境是生产环境，我根本不希望它超时。

我检查了文档 here ，但我找不到任何关于是否通过 0 的引用或 -1因为超时只会使作业永远运行(或直到它失败)。

有没有可能timeout可以解决问题的值？或任何其他不暗示调用 awaitTermination 的替代方案用于我的生产环境和 awaitTerminationOrTimeout对于我的 UAT 环境？

Answer 1

查看库后，我可以看到任何负值都可以。
awaitTerminationOrTimeout(timeout)内部电话streamingContext.awaitTerminationOrTimeout(timeout) ，然后调用 contextWriter.waitForStopOrError(timeout) .

内waitForStopOrError有一个条件，如果 timeout低于零，然后我们等待。

电话:DR :-1永远不会让作业超时。