CANNOT_LOAD_STATE_STORE condição de erro

Ocorreu um erro durante o estado de carregamento.

FALHA_NA_REPARAÇÃO_AUTOMÁTICA_DO_INSTANTÂNEO

Falha ao carregar a versão <latestSnapshot> do snapshot para o repositório de estado <stateStoreId>. Uma tentativa de reparo automático usando as versões instantâneas (<selectedSnapshots>) dos instantâneos disponíveis (<eligibleSnapshots>) também falhou.

CANNOT_FIND_BASE_SNAPSHOT_CHECKPOINT

Não é possível localizar um ponto de verificação de instantâneo base com linhagem: <lineage>.

CANNOT_READ_CHECKPOINT

Não é possível ler metadados de ponto de verificação do RocksDB. Esperado <expectedVersion>, mas encontrado <actualVersion>.

CANNOT_READ_DELTA_FILE_KEY_SIZE

Erro ao ler o arquivo delta <fileToRead> de <clazz>: o tamanho da chave não pode ser <keySize>.

CANNOT_READ_DELTA_FILE_NOT_EXISTS

Erro ao ler o arquivo <fileToRead> delta de <clazz>: <fileToRead> não existe.

CANNOT_READ_MISSING_SNAPSHOT_FILE

Erro ao ler o arquivo <fileToRead> de instantâneo de <clazz>: <fileToRead> não existe.

CANNOT_READ_SNAPSHOT_FILE_KEY_SIZE

Erro ao ler o arquivo de instantâneo <fileToRead> de <clazz>: o tamanho da chave não pode ser <keySize>.

CANNOT_READ_SNAPSHOT_FILE_VALUE_SIZE

Erro ao ler o arquivo de instantâneo <fileToRead> de <clazz>: o tamanho da chave não pode ser <valueSize>.

CANNOT_READ_STREAMING_STATE_FILE

Erro ao ler o arquivo de estado de streaming de <clazz>: <fileToRead> não existe. Se o trabalho de fluxo for reiniciado com uma operação de estado nova ou atualizada, crie um novo local de ponto de verificação ou desmarque o local de ponto de verificação existente.

CHECKPOINT_FILE_CHECKSUM_VERIFICATION_FAILED

<originalMessage>

CONFIGURATION_MISMATCH

O repositório de estado não foi carregado com êxito porque a configuração do repositório de estado não corresponde à configuração no ponto de verificação. Mensagem de erro: <errorMsg>

CONNECTION_POOL_SHUT_DOWN

Falha ao carregar o repositório de estado com a ID '<stateStoreId>' do provedor '<stateStoreProviderName>'. Mensagem de erro recuperada: <errorMsg>

CONEXÃO_RECUSADA

Falha ao carregar o repositório de estado com a ID <stateStoreId> do provedor <stateStoreProviderName> devido a um erro de conexão recusado. Mensagem de erro: <errorMsg>

FAILED_TO_GET_CHANGELOG_WRITER

Falha ao obter o gravador de log de alterações para o armazenamento de estado na versão <version>.

HDFS_STORE_PROVIDER_OUT_OF_MEMORY

Não foi possível carregar o armazenamento de estado do HDFS com id <stateStoreId> devido a uma exceção de falta de memória.

INCORRECT_NUMBER_FORMAT

O armazenamento de estado não foi carregado com sucesso. Mensagem de erro recuperada: <errorMsg>

INVALID_CHANGE_LOG_READER_VERSION

A versão do leitor de log de alterações não pode ser <version>. O ponto de verificação provavelmente é de uma versão futura do Spark, atualize o Spark.

INVALID_CHANGE_LOG_WRITER_VERSION

A versão do gravador do log de alterações não pode ser <version>.

LINHAGEM_DE_PONTO_DE_VERIFICAÇÃO_INVÁLIDA

Linhagem de ponto de verificação inválida: <lineage>. <message>

KEY_ROW_FORMAT_VALIDATION_FAILURE

<msg>

LOCAL_DISK_ERROR

Falha ao carregar o repositório de estado com a ID <stateStoreId> do provedor <stateStoreProviderName> devido a um erro de disco local. Um motivo comum para isso pode estar ficando sem espaço em disco local no executor.

ROCKSDB_STORE_PROVIDER_OUT_OF_MEMORY

Não foi possível carregar o armazenamento de estado do RocksDB com id <stateStoreId> devido a uma exceção de memória insuficiente.

VERIFICAÇÃO_DA_SOMA_DE_VERIFICAÇÃO_DA_LINHA_FALHOU

<originalMessage>

SNAPSHOT_PARTITION_ID_NOT_FOUND

ID da partição <snapshotPartitionId> não encontrado para o estado do operador <operatorId> em <checkpointLocation>.

UNCATEGORIZED

UNEXPECTED_FILE_SIZE

Copiado <dfsFile> para <localFile>, <expectedSize> bytes esperados, <localFileSize> bytes encontrados.

UNEXPECTED_VERSION

A versão não pode ser <version> porque é menor que 0.

UNRELEASED_THREAD_ERROR

<loggingId>: A instância do RocksDB não pôde ser adquirida por <newAcquiredThreadInfo> para operationType=<operationType>, pois não foi liberada por <acquiredThreadInfo> após <timeWaitedMs> ms.

O thread que mantém o bloqueio tem rastreamento: <stackTraceOutput>

VALUE_ROW_FORMAT_VALIDATION_FAILURE