scala - 如何在 Spark Executors 中检查广播变量的状态
问题描述
我有兴趣在 Spark 中跟踪广播变量的状态。我想知道在任务运行时广播变量在每个执行程序中消耗了多少内存，并确认在完成任务后调用 .unpersist() 后它没有被持久化。这可能吗？
解决方案
推荐阅读
- python - 将多个输入插入单行的数据框的字典列表？
- python - 获取一年中一周数的月数（Python）
- mysql - Sequelize - 使用 sequelize 函数将 iLike 查询转换为 MySQL 友好
- r - 从 OSM 星球文件中提取的内容不完整
- python - 在条件下懒惰地拆分Iterable
- javascript - 将动态值从 HTML 表单导入 App-Script
- javascript - 将生命周期方法反应到钩子
- reactjs - 如何将验证码集成到 Antd 表单的 onFinish 函数中
- python - PyAutoGui Nan NaN NaN
- swift - Swift 编译器失去了它的多态上下文