STREAMING_QUERY_EVOLUTION_ERROR condição de erro

SQLSTATE: 42000

Erro de evolução de consultas em streaming:

DUPLICATE_SOURCE_NAMES

Nomes duplicados de fontes de streaming detetados: <duplicateNames>. Cada fonte de streaming deve ter um nome único. Por favor, certifique-se de que todas as fontes têm nomes distintos usando o método name().

INVALID_SINK_NAME

Nome inválido do destino de streaming: '<sinkName>'. Os nomes dos pias devem conter ASCII apenas letras ('a'-'z', 'A'-'Z'), dígitos ('0'-'9') e sublinhas ('_').

INVALID_SOURCE_NAME

Fonte de streaming inválida: '<sourceName>'. Os nomes das fontes devem conter ASCII apenas letras ('a'-'z', 'A'-'Z'), dígitos ('0'-'9') e sublinhados ('_') . Use backticks para citar nomes com caracteres especiais, se necessário.

FONTES_NOMEADAS_EXIGEM_CUMPRIMENTO

Não é possível usar o método name() para nomear fontes de streaming quando o spark.sql.streaming.queryEvolution.enableSourceEvolution está desativado. Por favor, ative a evolução da fonte definindo spark.sql.streaming.queryEvolution.enableSourceEvolution como true, ou remova a chamada name().

FONTES_NOMEADAS_EXIGEM_REGISTRO_DE_OFFSET_V2

A aplicação de fontes de streaming nomeadas requer o formato de log offset V2 (OffsetMap), mas encontrou V<version>. O formato V2 utiliza pares sourceId:offset que suportam evolução de código-fonte. Defina spark.sql.streaming.offsetLog.version para 2, ou desative a imposição de fontes nomeadas definindo spark.sql.streaming.queryEvolution.enableSourceEvolution como false

SINK_ID_REUTILIZADO

Não é possível reutilizar o nome do coletor '<sinkId>' do ponto de controlo no local <checkpointLocation>. Este nome de pia era usado anteriormente e depois substituído por outro. Reutilizar nomes de sinks inativos pode causar problemas de correção dos dados. Para usar um novo sink, atribui-lhe um nome diferente usando o método name() no DataStreamWriter (por exemplo, .name("my_new_sink")).

SINK_PROVIDER_MISMATCH

Não é possível mudar o fornecedor do lavatório para o lavatório '<sinkId>' no local <checkpointLocation>do ponto de controlo. A pia estava anteriormente a usar o fornecedor '<previousProvider>', mas agora está a usar '<currentProvider>'. Mudar o tipo de lavatório mantendo o mesmo nome pode causar problemas de correção dos dados. Para usar o novo tipo de sink, atribui-lhe um nome diferente usando o método name() no DataStreamWriter (por exemplo, .name("my_new_sink")).

TOMBSTONE_SOURCE_NAME_REUSE

Não é possível reutilizar nomes de fontes com lápides: <sourceNames>. Estes nomes de origem foram usados anteriormente e depois removidos da consulta de streaming no local do checkpoint <checkpointLocation>. Reutilizar nomes de fontes com lápides pode causar problemas de correção dos dados. Por favor, use nomes de fontes diferentes.

SINKS_DE_STREAMING_SEM_NOME_COM_EXECUÇÃO

O sink de streaming deve ser nomeado quando o spark.sql.streaming.queryEvolution.enableSinkEvolution estiver ativado. Utilize o método name() no DataStreamWriter para atribuir um nome ao destino de fluxo.

FONTES_DE_STREAMING_NÃO_NOMEADAS_COM_IMPOSIÇÃO

Todas as fontes de streaming devem ser nomeadas quando o spark.sql.streaming.queryEvolution.enableSourceEvolution estiver ativado. Fontes anónimas encontradas: <sourceInfo>. Use o método name() para atribuir nomes a todas as fontes de streaming.