checkpointlocation专题

Spark-StructuredStreaming checkpointLocation分析、优化耗时

目录 1 问题描述2 分析 checkpointLocation 配置 2.1 checkpointLocation 在源码调用链2.2 MetadataLog(元数据日志接口) 3 分析 checkpointLocation 目录内容 3.1 offsets 目录3.2 commitLog 目录3.3 metadata 目录3.4 sources 目录3.5 sinks 目录 4 解决方案 4