STREAMING_UNRESUMABLE_CONTROL_BATCH_DETECTED Fehlerzustand

SQLSTATE: 55019

Der unvollständige Kontroll-Batch <batchId> kann nicht fortgesetzt werden.

NEU PARTITIONIEREN

Der Repartitionierungs-Batch verfügt über <unfinishedNumPartition> Zustandspartitionen, die aktuelle Abfrage fordert jedoch <requestedNumPartition> an.

Legen Sie spark.sql.streaming.stateStore.partitions auf <unfinishedNumPartition>, und führen Sie die Abfrage erneut aus. Nachdem die Neupartitionierung erfolgreich abgeschlossen ist, können Sie sie in <requestedNumPartition> ändern

SET_CHECKPOINT_PROPERTIES

Session conf <confKey> stimmt nicht mit dem Wert <confValue> überein, der vom ausstehenden Batch für die Abfrage <queryId>erforderlich ist.