STREAMING_CHECKPOINT_METADATA_ERROR condizione di errore

SQLSTATE: 42616

Errore nei metadati del checkpoint di streaming.

COMMIT_LOG_V3_METADATA_DESTINAZIONE_MANCANTE

Se si usa spark.sql.streaming.commitLog.formatVersion >= 3, è necessario specificare le informazioni sui metadati del sink. Si prega di correggere le configurazioni e riprovare, poiché alcune modalità di streaming non sono compatibili con questa versione del formato (modalità continua, rilevamento asincrono del progresso, checkpoint dello stato asincrono).

RILEVATO_BATCH_CONTROLLO_IN_ATTESA

Rilevato batch di controllo in sospeso per operationType=<operationType> con batchId=<batchId> e queryId=<queryId>. Ripetere l'operazione di controllo ed eseguire di nuovo la query.

RILEVATA_QUERY_IN_ESECUZIONE

È stata rilevata l'esecuzione di query di streaming con ID <queryId>. Arrestare la query in esecuzione prima di eseguire di nuovo il riavvolgimento.

METADATI_DI_LOG_DI_COMMIT_NON_VALIDI

Sono stati trovati metadati del log di commit non validi per batch <batchId> nella versione del formato <commitLogFormatVersion>. Eseguire di nuovo la query con la configurazione corretta.

PROGRESSO_COMMIT_NON_TROVATO

Si è verificato un errore durante il viaggio nel tempo abilitato per il batch <batchId>. Per favore, disabilita il viaggio nel tempo o contatta il supporto Azure Databricks.

FILE_DI_METADATI_MANCANTE

La posizione <checkpointLocation> del checkpoint è in uno stato incoerente: il file di metadati è mancante, ma i log di offset e/o di commit contengono dati. Ripristinare il file di metadati o creare una nuova directory di checkpoint.

NO_QUERY_ID_FOUND

Nessun ID query di streaming trovato nel percorso <checkpointLocation> del checkpoint. Controllare se il percorso del checkpoint è valido.

REWIND_COMMIT_MISSING_SINK_METADATA

Si è tentato di riavvolgere il batch <batchId> al percorso di checkpoint <checkpointLocation>, ma non è stato creato con spark.sql.streaming.commitLog.formatVersion >= 3. Nessuno metadati di ricezione disponibili nel log di commit. Riprovare con un batch con metadati sink disponibili oppure eseguire di nuovo la query con la configurazione corretta.

RIPRISTINO_OFFSET_METADATA_MANCANTE

Si è tentato di riavvolgere il batch <batchId> in corrispondenza della posizione <checkpointLocation> del checkpoint, ma non sono disponibili metadati nel log di offset. Riprovare con un batch con metadati disponibili.

SKIP_OFFSETS_IDENTIFICATORE_SORGENTE_NON_VALIDO

L'ID <sourceId> di origine non valido in skipOffsets in batchId=<batchId> non esiste negli ID di origine disponibili=<availableSourceIds> per il percorso <checkpointLocation>del checkpoint . Controlla se la query è stata modificata per rimuovere questa origine e aggiungerla nuovamente.

FONTE_NON_SUPPORTA_SALTA_OFFSET

L'origine <sourceName> non supporta il salto degli offset. Si prega di rimuovere questa origine dalla query o riavvolgere senza ignorare gli offset.

METADATI_STATO_MANCANTI_PER_REWIND

Impossibile leggere i metadati dello stato per l'operatore <operatorId> in batch <batchId> durante l'operazione di riavvolgimento. Posizione del checkpoint: <checkpointLocation>. Il file di metadati potrebbe non esistere per questo batch. Verificare che il batch di destinazione abbia metadati di stato validi prima del riavvolgimento.

STATE_STORE_MIGRATION_WITH_TIME_TRAVEL_UNSUPPORTED

Non è supportato il rendere possibile il viaggio nel tempo e migrare il provider dello state store nello stesso riavvio della query. Completa prima la migrazione del provider del negozio statale, poi abilita il viaggio nel tempo in un successivo riavvio. Posizione del checkpoint: <checkpointLocation>.