有一种方法可以通过将属性设置spark.streaming.stopGracefullyOnShutdown为 true 来正常关闭 Spark Streaming,然后使用命令终止进程kill -SIGTERM。但是我没有看到这样的选项可用于结构化流(SQLContext.scala)。
spark.streaming.stopGracefullyOnShutdown
kill -SIGTERM
结构化流的关闭过程是否不同?或者只是还没有实施?
apache-spark spark-streaming apache-spark-sql spark-structured-streaming
apache-spark ×1
apache-spark-sql ×1
spark-streaming ×1
spark-structured-streaming ×1