Condividi tramite


STREAMING_CHECKPOINT_REWIND_ERROR condizione di errore

SQLSTATE: 42000

Impossibile eseguire l'operazione di riavvolgimento per la query in streaming con checkpoint location=<checkpointLocation>.

IMPOSSIBILE_TROVARE_FORNITORI_DI_REWIND_DEL_SINK

Impossibile trovare fornitori di riavvolgimento per sink in batchId=<batchId>.

ERRORE_NEL_TROVARE_FORNITORI_DI_REWIND_DELLE_FONTI

Impossibile trovare i provider di riavvolgimento di origine in batchId=<batchId>.

INVALID_REWIND_PROVIDER

Trovato provider di riavvolgimento di origine/sink non valido con il nome=<rewindProviderName> al batchId=<batchId>. Nome del provider sorgente/destinazione=<providerName> per <sourceOrSinkId>.

SINK_NON_SUPPORTA_RIAVVOLGIMENTO_RIPRODUZIONE

Il sink <sinkName> non supporta il viaggio nel tempo. Si prega di disabilitare il viaggio nel tempo o contattare il supporto di Databricks.

SOURCE_ID_NOT_FOUND_IN_OFFSETS

L'ID di origine '<sourceId>' nel batchId=<batchId> non è stato trovato nel log degli offset più recente nella posizione <checkpointLocation> del checkpoint.

ID di origine disponibili: [<availableSourceIds>].

Questo errore può verificarsi se la query di streaming è stata modificata per aggiungere una nuova origine dopo il batch di destinazione di riavvolgimento.

Assicurarsi che tutte le origini nella configurazione della query corrente esistano nel lotto di rewind di destinazione.

SOURCE_OFFSET_METADATA_MISMATCH

Mancata corrispondenza dei metadati dell'offset di origine in batchId=<batchId>. Numero previsto di sorgenti=<expectedNumSources>, ma il conteggio ottenuto è=<actualNumSources>.

VIAGGIO_NEL_TEMPO_NON_ABILITATO

Il viaggio nel tempo non è abilitato per la posizione del checkpoint <checkpointLocation>. Abilitare il viaggio nel tempo prima di eseguire il riavvolgimento. Per le nuove query, abilitare il viaggio nel tempo impostando spark.databricks.streaming.queryMgmt.rewindReplay.enabled su true.

VERSIONE DI LOG OFFSET NON SUPPORTATA

La versione <version> del log offset non è supportata in batchId = <batchId>. Per usare Rewind è necessario la versione 2 del log di offset. Verificare che il checkpoint sia stato creato con la versione 2 del registro di offset abilitata.