warunek błędu STREAMING_UNRESUMABLE_CONTROL_BATCH_DETECTED

SQLSTATE: 55019

Nie można wznowić niedokończonej partii <batchId> kontrolnej.

PODZIAŁ

Partia repartycjonowania ma <unfinishedNumPartition> partycji stanu, ale bieżące zapytanie wymaga <requestedNumPartition>.

Ustaw spark.sql.streaming.stateStore.partitions na <unfinishedNumPartition>, a następnie uruchom ponownie zapytanie. Gdy to ponowne partycjonowanie zakończy się pomyślnie, możesz zmienić to na <requestedNumPartition>

SET_CHECKPOINT_PROPERTIES

<confKey> Konfiguracja sesji nie jest zgodna z wartością <confValue> wymaganą przez oczekującą partię dla zapytania <queryId>.