状态重写器无效检查点错误状态

SQLSTATE:55019

状态重写检查点位置“”<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。