STATE_STORE_PROVIDER_MIGRATION_INVALID_CHECKPOINT错误条件

SQLSTATE:55019

状态存储提供程序迁移检查点位置“<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(及其子类)。