apache-spark - 如果会话停止,Spark 上下文会发生什么情况?
问题描述
spark
如果我停止一个名为的现有 Spark 会话spark.stop()
,它的上下文会发生什么?是不是也自动杀了?我问是因为我接管了一些代码,上面写着:
spark.stop()
sc.stop()
我想知道我是否需要第二个命令。
解决方案
感谢如何检查 SparkContext 是否已停止?我找到了方法isStopped
,如果我运行
spark.stop()
spark.sparkContext.isStopped
它返回“真”。因此,似乎停止会话也会停止上下文,即我的第一篇文章中的第二个命令是多余的。
请注意,在 PysparkisStopped
中似乎不起作用:“'SparkContext' 对象没有属性 'isStopped'”。我用 Spark Scala 进行了检查。
推荐阅读
- python - 如何将通用变量文件与 Python 一起用于子文件夹?
- github-actions - 在 GitHub Actions 工作流作业中为环境使用动态输入值
- python - python google api创建具有权限的文件夹
- qt - 嵌入式 QT5 键盘自动重复不起作用
- php - 验证不起作用 Laravel 对 bcrypted 密码的自定义身份验证
- javascript - 如果缓存中存在则加载类
- android - 设置点击监听器到 TextInputEditText drawable Right/End android studio
- sql - 在 ORACLE 中使用 GROUP BY 和 HAVING COUNT(condition) 的 SQL 查询
- javascript - JavaScript Array of Arrays:想要获取值为 'PROCESSED' 的第一行
- c# - 将复杂的 SQL 查询转换为 LINQ