2
如果我希望在程序化方式中以异常或特定用例的形式停止Spark应用程序,请从Java代码实现此操作。 我试图调用JavaSparkContext.close(),但仍似乎正在运行该作业。如何以编程方式停止Spark作业执行
如果我希望在程序化方式中以异常或特定用例的形式停止Spark应用程序,请从Java代码实现此操作。 我试图调用JavaSparkContext.close(),但仍似乎正在运行该作业。如何以编程方式停止Spark作业执行
您可以使用下面的方法,来取消正在运行的火花工作:
cancelJobGroup(String group Id)
- 取消活动作业指定组。
cancelAllJobs()
- 取消所有已安排或正在运行的作业。
欲了解更多详情,请参阅API doc