STREAMING_UNRESUMABLE_CONTROL_BATCH_DETECTED エラー条件

SQLSTATE: 55019

未完了の制御バッチ <batchId> は再開できません。

再パーティション化

再パーティション バッチには <unfinishedNumPartition> 個の状態パーティションがありますが、現在のクエリは <requestedNumPartition> を要求しています。

spark.sql.streaming.stateStore.partitions を <unfinishedNumPartition>に設定し、クエリを再実行します。 その再パーティションが正常に完了したら、その後それを <requestedNumPartition> に変更できます。

SET_CHECKPOINT_PROPERTIES

セッションの conf <confKey> は、クエリ <queryId> の保留中のバッチで必要とされる値 <confValue> と一致しません。