星火流正常关机

Question

我看到有两个地方配置正常关机的选项：

1. 在定义火花的conf：

“spark.streaming.stopGracefullyOnShutdown”，“真”。

1. 当停止流上下文：

JavaStreamingContext SCC;

scc.stop（真，真）

。这两个选项之间的差异？

感谢

开始=>

Answer 1

第一种方式

sparkConf.set(“spark.streaming.stopGracefullyOnShutdown","true") 

火花配置这个参数设置为true，确保在新的Spark版本的 适当的正常关机（1.4起） 应用。此外，我们不应该使用第一个明确的关机钩 方法或在驱动程序中调用ssc.stop方法以及此 参数。我们可以设置这个参数，然后调用方法 ssc.start()和ssc.awaitTermination()。无需拨打ssc.stop 方法。否则应用程序可能在关机期间挂起

第二种方式 scc.stop(true,true)

的scc.stop()方法的第一个boolean变量是停止 相关火花背景下，而第二boolean变量为流媒体方面的 正常关机

这已明确提及herechandan prakash

希望这有助于！