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_RIPRISTINARE_IL_SINK_CON_MISSING_SINK_OFFSET

Impossibile eseguire il rewind con restoreSink=true perché sinkOffset <sinkOffset> non è valido. Riavvolgi a un batch diverso o imposta restoreSink=false.

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>.

IL_DISPOSITIVO_DI_SINK_NON_SUPPORTA_IL_RIPRISTINO

Sink <sinkName> non supporta 'restoreSink=true' per il viaggio nel tempo. Devi impostare 'restoreSink=false' nella configurazione di riavvolgimento.

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>.

STATE_RESTORATION_FAILED

Impossibile ripristinare l'archivio stati dal batch <sourceBatchId> di origine al batch <targetBatchId>.

Verificare che i file del checkpoint di stato esistano e non siano danneggiati nel batch di origine o scegliere un batch diverso per riavvolgere.

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.

PROVIDER_ARCHIVIAZIONE_STATO_NON_SUPPORTATO

Il riavvolgimento con mantenimento dello stato non è supportato per il provider dell'archivio di stato <providerClass>.

Solo l'archivio di stato RocksDB è supportato per le operazioni di riavvolgimento con stato.