我有3个笔记本流水线并行运行在同一个集群上,我想知道是否有任何方法可以清除一个笔记本的所有scala变量并触发dfs而不影响其他笔记本?我尝试了spark.close(),但它清除了其他两个笔记本的状态。我知道分离笔记本会清除状态,但如何使用命令?我还想知道是否有任何方法调用gc并清除垃圾。先谢谢你。
vdzxcuhz1#
您需要在 Package 类对象中定义代码,以便在出现任何错误时可以重新声明该对象。
1条答案
按热度按时间vdzxcuhz1#
您需要在 Package 类对象中定义代码,以便在出现任何错误时可以重新声明该对象。