STREAMING_CHECKPOINT_REWIND_ERROR condição de erro

SQLSTATE: 42000

Falhou a realização da operação de retrocesso para a consulta de streaming com localização do checkpoint=<checkpointLocation>.

CANNOT_RESTORE_SINK_WITH_MISSING_SINK_OFFSET

Retroceder com restoreSink=true não pode ser realizado porque o sinkOffset <sinkOffset> não é válido. Rebobine para outro lote ou configure restoreSink=false.

FALHA_AO_ENCONTRAR_FORNECEDORES_REWIND_DE_SINK

Não foi possível encontrar os provedores de retrocesso de sink com batchId=<batchId>.

FALHA_AO_ENCONTRAR_PROVEDORES_DE_REBOBINAGEM_DE_ORIGEM

Falha ao encontrar fornecedores de reinicialização de origem em batchId=<batchId>.

FORNECEDOR_DE_RETROCESSO_INVÁLIDO

Foi encontrado um fornecedor inválido de rebobinar fonte/sink com nome=<rewindProviderName> no batchId=<batchId>. Nome do fornecedor Source/Sink = <providerName> para <sourceOrSinkId>.

O_SINK_NÃO_SUPORTA_RESTAURAR

O Sink <sinkName> não suporta 'restoreSink=true' para viagens no tempo. Defina 'restoreSink=false' nas definições de rewind.

O_SINK_NÃO_SUPORTA_REBOBINAR_REPRODUZIR

O Sink <sinkName> não suporta viagem no tempo. Por favor, desative o Time Travel ou contacte o suporte da Databricks.

ID_FONTE_NÃO_ENCONTRADO_NOS_DESLOCAMENTOS

O ID da fonte '<sourceId>' no batchId=<batchId> não foi encontrado no registo de deslocamento mais recente na localização do ponto de verificação <checkpointLocation>.

IDs de fonte disponíveis: [<availableSourceIds>].

Este erro pode ocorrer se a consulta de fluxo contínuo foi modificada para adicionar uma nova fonte após o lote alvo de retorno.

Certifique-se de que todas as fontes enumeradas na configuração de consulta atual já existiam no lote de retrocesso alvo.

SOURCE_OFFSET_METADATA_MISMATCH

Incompatibilidade de metadados de offset de origem em batchId=<batchId>. Número esperado de fontes=<expectedNumSources>, mas a contagem foi=<actualNumSources>.

Falha na Restauração do Estado

Falhou ao restaurar o armazenamento de estado do lote de origem <sourceBatchId> para o lote <targetBatchId>.

Verifique se os ficheiros de checkpoint de estado existem e não estão corrompidos no lote de origem ou escolha um lote diferente ao qual retroceder.

VIAGEM_NO_TEMPO_NÃO_ATIVADA

A viagem no tempo não está ativada para a localização <checkpointLocation>dos pontos de controlo. Por favor, ative a viagem no tempo antes de realizar o rewind. Para novas consultas, ative a viagem no tempo definindo spark.databricks.streaming.queryMgmt.rewindReplay.enabled como verdadeiro.

VERSÃO_DO_REGISTRO_DE_DESLOCAMENTO_NÃO_SUPORTADA

Versão <version> de log offset não suportada no batchId=<batchId>. Rewind requer uma versão de log de offset 2. Certifique-se de que o checkpoint foi criado com o log offset versão 2 ativada.

PROVEDOR_DE_ARMAZENAMENTO_DE_ESTADO_NÃO_SUPORTADO

O rewind com estado não é suportado para o fornecedor <providerClass>da loja estatal.

Apenas o RocksDB state store é suportado para operações de rebobinado com estado.