流式处理检查点元数据时出错。
COMMIT_LOG_V3_缺少接收器元数据
如果使用 spark.sql.streaming.commitLog.formatVersion >= 3,那么必须提供汇元数据信息。 某些流模式与此格式版本不兼容(连续模式、异步进度跟踪、异步状态检查点):请修复配置,然后重试。
无效提交日志元数据 (INVALID_COMMIT_LOG_METADATA)
发现批处理<batchId>
的提交日志元数据无效,格式版本为<commitLogFormatVersion>
。 请使用正确的配置重新运行查询。
REWIND_COMMIT_MISSING_SINK_METADATA
尝试将检查点位置的批次 <batchId>
回滚至 <checkpointLocation>
,但该批次不是使用 spark.sql.streaming.commitLog.formatVersion >= 3 创建的。 提交日志中没有可用的汇元数据。 请使用可用的接收器元数据的批处理重试,或使用正确的配置重新运行查询。