apache-spark - 如何在 Zeppelin 上的 Apache Spark 中停止 StreamingContext

Question

import org.apache.spark.streaming.{Seconds, StreamingContext}
import org.apache.spark.streaming.eventhubs.EventHubsUtils
import sqlContext.implicits._

val ehParams = Map[String, String](
    "eventhubs.policyname" -> "Full",
...
)

val ssc = new StreamingContext(sc, Seconds(2))
val stream = EventHubsUtils.createUnionStream(ssc, ehParams)
val cr = stream.window(Seconds(6))

case class Message(msg: String)
stream.map(msg=>Message(new String(msg))).foreachRDD(rdd=>rdd.toDF().registerTempTable("temp"))

stream.print
ssc.start

<小时/>

上面的内容启动并运行良好，但我似乎无法阻止它。任何对 %sql show table 的调用都会卡住。

如何停止上面的 StreamingContext ？

Answer 1

ssc.stop 还会终止 Spark 上下文，需要重新启动解释器。

改用ssc.stop(stopSparkContext=false, stopGraceously=true)。