Pular para o conteúdo principal

transmissão condição de erro

SQLSTATE: 0A000

O modo de transmissão tempo real tem a seguinte limitação:

OPERAÇÕES_ESTATAIS_ARBITRÁRIAS_NÃO SUPORTADAS

O operador de transmissão arbitrária com estado, <op>, não é suportado no momento. Consulte o tempo real Mode Guia do usuário para obter uma lista dos operadores compatíveis.

RASTREAMENTO ASYNC_PROGRESS_NÃO SUPORTADO

O acompanhamento do progresso assíncrono não é compatível com o modo tempo real. Defina a opção AsyncProgressTrackingEnabled como falsa e repita sua consulta.

ASYNC_STATE_CHECKPOINT_NOT_SUPPORTED

O checkpointing de estado assíncrono não é compatível com o modo de tempo real. Defina spark.databricks.transmissão.statefulOperator.asyncCheckpoint.enabled como false e tente novamente a consulta.

UNIÃO EM LOTE NÃO SUPORTADA

o modo tempo real não suporta a união com lotes fonte de dados. Certifique-se de que a consulta de transmissão de união contenha apenas fontes de dados de transmissão.

CHECKPOINT_V2_REQUIRED

O modo em tempo real requer o ponto de verificação v2. Definir spark.sql.transmissão.stateStore.checkpointFormatVersion até 2 e repita sua consulta.

concorrente

O modo tempo real requer o programador DAG do estágio concorrente. Reinicie o spark clustering e defina spark.databricks.dagScheduler.type como ConcurrentStageDAGScheduler.

DROP_DUPLICATES_WITHIN_WATERMARK_NOT_SUPPORTED

DropDuplicatesWithinWatermark não é suportado. Para contornar essa limitação, você pode usar DropDuplicates em vez disso. Lembre-se de passar sua coluna de horário do evento para DropDuplicates para que esse estado possa ser eliminado.

EVENT_TIME_BASED_TIMERS_IN_TRANSFORM_WITH_STATE_NOT_SUPPORTED

Ainda não há suporte para temporizadores baseados em tempo de evento no operador transformWithState. Se você quiser usar o operador transformWithState, especifique o tempo de processamento em seu operador transformWithState e tente sua consulta novamente.

FONTES_DE_ORIGENS IDÊNTICAS EM _UNION_NOT_SUPPORTED

O modo tempo real não suporta a união de duas ou mais fontes de dados de transmissão idênticas em uma única consulta. Isso inclui cenários como a referência à mesma fonte DataFrame mais de uma vez ou o uso de duas fontes de dados com configurações idênticas para algumas fontes. Para o Kafka, evite reutilizar o mesmo DataFrame e crie outros diferentes. No caso do Kinesis, além de duplicar os quadros de dados, certifique-se de que cada DataFrame defina um valor exclusivo para a opção "consumerName". Fontes fornecidas na consulta: <sources>

INPUT_STREAM_NÃO SUPORTADO

A transmissão de entrada <className> não é suportada. Consulte o tempo real Mode Guia do usuário para obter uma lista das transmissões de entrada compatíveis.

GERENCIADOR MULTI_SHUFFLE_OBRIGATÓRIO

O modo em tempo real requer o gerenciador de multi-shuffle. Defina spark.shuffle.manager como org.apache.spark.shuffle.transmissão.MultiShuffleManager e reinicie o clustering do spark.

OPERADOR_OR_SINK_NOT_IN_ALLOWLIST

O <errorType>(s): <message> não está na lista de permissão do <errorType> para o tempo real Mode. Para ignorar essa verificação, defina spark.databricks.transmissão.realTimeMode.allowlistCheck como false. Ao alterar isso, o senhor concorda em executar a consulta por sua própria conta e risco.

MODO DE SAÍDA NÃO SUPORTADO

O modo de saída <outputMode> não é suportado. Para contornar essa limitação, defina o modo de saída como Atualizar. No futuro, o <outputMode> poderá ser suportado.

ROCKSDB_STATE_STORE_PROVIDER_OBRIGATÓRIO

O modo tempo real requer o provedor RocksDB armazenamento do estado ou provedores que o estendam. Definir spark.sql.transmissão.stateStore.providerClass para org.apache.spark.sql.execution.transmissão.state.RocksDBStateStoreProvider e tente novamente a consulta.

SESSÃO_WINDOWS_NÃO SUPORTADA

As janelas de sessão ainda não são suportadas. As únicas agregações de janelas permitidas são janelas caídas e deslizantes.

EXECUÇÃO_ESPECULATIVA_NÃO SUPORTADA

A execução especulativa não é compatível com o modo de tempo real. Defina spark.speculation como false e reinicie o clustering do spark.

OPERADORES_ESTATAIS_BEFORE_UNION_NOT_SUPPORTED

As consultas de transmissão no modo tempo real não podem incluir operadores com estado (por exemplo, o agregado, desduplicado, transformWithState) antes de uma união. Reestruture sua consulta para aplicar a união antes de qualquer operação stateful.

transmissão

Ainda não há suporte para nenhum tipo de união de transmissão.