Spark上下文和流上下文的組合

Question

我想在流上下文停止後執行一些批處理計算。 （strContext.stop（true，true）

我認爲停止流上下文會導致停止相關的火花上下文實際上我收到一個關於火花偵聽器總線的錯誤 看來，甚至調用strContext.stop（假，真）會導致火花上下文的執行停止。

任何人都可以流後，提供一批計算的例子嗎？

Answer 1

def stop(stopSparkContext: Boolean, stopGracefully: Boolean): Unit = { 
    ... 
    if (stopSparkContext) sc.stop() 
} 

從上面的代碼，如果傳遞strContext.stop（false），則不應停止Spark Context。

你是否停止了一些其他的代碼。你可以在這裏粘貼你的代碼嗎？