STREAMING_UNRESUMABLE_CONTROL_BATCH_DETECTED condição de erro

SQLSTATE: 55019

O lote <batchId> de controlo inacabado não pode ser retomado.

REPARTIÇÃO

O lote reparticionado tem <unfinishedNumPartition> partições de estado, mas a consulta atual solicita <requestedNumPartition>.

Defina spark.sql.streaming.stateStore.partitions para <unfinishedNumPartition>, e execute novamente a consulta. Quando essa repartição terminar com sucesso, podes mudá-la para <requestedNumPartition>

SET_CHECKPOINT_PROPERTIES

A session conf <confKey> não corresponde ao valor <confValue> exigido pelo lote pendente para a consulta <queryId>.