Condition d'erreur CANNOT_LOAD_STATE_STORE

Une erreur s’est produite lors du chargement.

AUTO_SNAPSHOT_REPAIR_FAILED

Impossible de charger la version d’instantané <latestSnapshot> pour le magasin d'état <stateStoreId>. Une tentative de réparation automatique à l’aide de versions d’instantanés (<selectedSnapshots>) parmi les instantanés disponibles (<eligibleSnapshots>) a également échoué.

CANNOT_FIND_BASE_SNAPSHOT_CHECKPOINT

Impossible de trouver un point de contrôle d’instantané de base avec traçabilité : <lineage>.

CANNOT_READ_CHECKPOINT

Impossible de lire les métadonnées de point de contrôle RocksDB. <expectedVersion> était attendu, mais <actualVersion> a été trouvé.

CANNOT_READ_DELTA_FILE_KEY_SIZE

Erreur de lecture du fichier delta <fileToRead> de <clazz> : la taille de clé ne peut pas être <keySize>.

CANNOT_READ_DELTA_FILE_NOT_EXISTS

Erreur lors de la lecture du fichier de delta <fileToRead> de <clazz> : <fileToRead> n’existe pas.

CANNOT_READ_MISSING_SNAPSHOT_FILE

Erreur lors de la lecture du fichier d’instantané <fileToRead> de <clazz> : <fileToRead> n’existe pas.

CANNOT_READ_SNAPSHOT_FILE_KEY_SIZE

Erreur lors de la lecture du fichier d’instantané <fileToRead> de <clazz> : la taille de la clé ne peut pas être <keySize>.

CANNOT_READ_SNAPSHOT_FILE_VALUE_SIZE

Erreur de lecture du fichier capture instantanée <fileToRead>de<clazz> : la taille de valeur ne peut pas être <valueSize>.

CANNOT_READ_STREAMING_STATE_FILE

Erreur lors de la lecture du fichier d’état de streaming de <clazz> : <fileToRead> n’existe pas. Si la tâche de flux est redémarrée avec une opération d’état nouvelle ou mise à jour, créez un nouvel emplacement du point de contrôle ou effacez l’emplacement existant du point de contrôle.

CANNOT_WRITE_STREAMING_STATE_FILE

Échec d’écriture du fichier de stockage d’état en streaming car l’emplacement du point de contrôle est en lecture seule ou l’identité n’a pas l’autorisation d’écriture. Assurez-vous que l’emplacement du point de reprise est accessible en écriture. Message d’erreur : <errorMsg>

CHECKPOINT_FILE_CHECKSUM_VERIFICATION_FAILED

<originalMessage>

CONFIGURATION_MISMATCH

Le magasin d’états n’a pas pu se charger correctement, car la configuration du magasin d’état ne correspond pas à la configuration dans le point de contrôle. Message d’erreur : <errorMsg>

CONNECTION_POOL_SHUT_DOWN

Impossible de charger le magasin d’état avec l’ID « <stateStoreId> » à partir du fournisseur « <stateStoreProviderName> ». Message d’erreur récupéré : <errorMsg>

CONNEXION_REFUSÉE

Impossible de charger le magasin d’états avec l’ID <stateStoreId> du fournisseur <stateStoreProviderName> en raison d'une erreur de connexion refusée. Message d’erreur : <errorMsg>

FAILED_TO_GET_CHANGELOG_WRITER

Impossible d’obtenir l’enregistreur de journal des modifications pour le magasin d’états à la version <version>.

HDFS_STORE_PROVIDER_OUT_OF_MEMORY

Impossible de charger le magasin d’état HDFS portant l’ID <stateStoreId> en raison d’une exception de mémoire insuffisante.

INCORRECT_NUMBER_FORMAT

Échec du chargement du magasin d’état. Message d’erreur récupéré : <errorMsg>

INVALID_CHANGE_LOG_READER_VERSION

La version du lecteur du journal des modifications ne peut pas être <version>. Le point de contrôle provient probablement d'une version future de Spark, veuillez mettre à jour votre Spark.

INVALID_CHANGE_LOG_WRITER_VERSION

La version de l’enregistreur de journaux de modification ne peut pas être <version>.

INVALID_CHECKPOINT_LINEAGE

Traçabilité de point de contrôle non valide : <lineage>. <message>

KEY_ROW_FORMAT_VALIDATION_FAILURE

<msg>

LOCAL_DISK_ERROR

Impossible de charger le magasin d’états avec l’ID <stateStoreId> du fournisseur <stateStoreProviderName> en raison d’une erreur de disque local. Une raison courante de ce problème peut être d’épuisement de l’espace disque local sur l’exécuteur.

ROCKSDB_STORE_PROVIDER_OUT_OF_MEMORY

Impossible de charger le magasin d’état RocksDB d’ID <stateStoreId> en raison d’une exception de manque de mémoire.

ROW_CHECKSUM_VERIFICATION_FAILED

<originalMessage>

SNAPSHOT_PARTITION_ID_NOT_FOUND

ID de partition <snapshotPartitionId> introuvable pour l’état de l’opérateur <operatorId> sur <checkpointLocation>.

UNCATEGORIZED

UNEXPECTED_FILE_SIZE

Copié <dfsFile> vers <localFile>, <expectedSize> octets attendus, <localFileSize> octets trouvés.

UNEXPECTED_VERSION

La version ne peut pas être <version> parce qu’elle est inférieure à 0.

UNRELEASED_THREAD_ERROR

<loggingId>: l’instance RocksDB n’a pas pu être obtenue par <newAcquiredThreadInfo> pour le type d’opération=<operationType>, car elle n’a pas été libérée par <acquiredThreadInfo> après <timeWaitedMs> ms.

Le thread qui détient le verrou a une trace : <stackTraceOutput>

VALUE_ROW_FORMAT_VALIDATION_FAILURE