状态重写检查点位置“”<checkpointLocation>处于无效状态。
MISSING_COMMIT_METADATA
在进行流式查询执行时,您可能为“spark.sql.streaming.minBatchesToRetain”配置设定了一个过低的值。
或删除了检查点位置中的文件。
MISSING_KEY_ENCODER_SPEC
列族<colFamilyName>需要关键状态编码器规格,但未找到。
请确保检查点来自受支持的 Spark 版本(Spark 4.0+)或 DBR 14.3+。
缺少操作员元数据
找不到批处理 <batchId>的有状态运算符元数据。
确保检查点适用于有状态流式处理查询,并且查询是在支持操作元数据的 Spark 版本(Spark 4.0+)或 DBR 14.3+ 上运行。
UNSUPPORTED_STATE_STORE_METADATA_VERSION
遇到不受支持的状态存储元数据版本。
仅支持 StateStoreMetadataV1 和 StateStoreMetadataV2。