状态存储提供程序迁移检查点位置“<checkpointLocation>”处于无效状态。
最后一批处理失败
最后一批 <lastBatchId> 尚未提交。
所有数据批次都必须在状态存储提供程序迁移之前提交。
缺少偏移序列元数据
批次 <batchId> 缺少 offset seq 元数据(offset seq 版本 <version>)。
未找到批次
在偏移日志中没有发现任何批次。
NO_COMMITTED_BATCH
提交日志中不存在已提交的批次。
要使用目标状态存储提供程序开始新的查询,请设置
直接使用 spark.sql.streaming.stateStore.providerClass,而不是使用该配置项
spark.databricks.streaming.stateStore.migrateStateStoreProvider 标志。
OFFSET_SEQ_NOT_FOUND
未找到批次 <batchId> 的偏移序号。
SAME_PROVIDER
源和目标状态存储提供商都是 <providerClass>。
没有什么需要迁移的。
STATELESS_QUERY
查询没有带状态的操作符,因此没有状态存储可供迁移。
不支持的偏移序列版本
偏移排序版本 <version> 不支持州存储提供商迁移。
UNSUPPORTED_SOURCE_PROVIDER
<providerClass> 不支持用作状态存储提供程序迁移的源。
仅支持 HDFSBackedStateStoreProvider(及其子类)。
UNSUPPORTED_TARGET_PROVIDER
不支持将 <providerClass> 作为状态存储提供程序迁移的目标。
仅支持 RocksDBStateStoreProvider(及其子类)。