Realtime Compute for Apache Flink:Módulo de pipeline do Flink CDC

Parâmetro

Descrição

Obrigatório

Tipo de dados

Valor padrão

Observação

name

Nome do job de ingestão de dados do Flink CDC.

Não

STRING

Flink CDC Pipeline Job

-

schema.change.behavior

Estratégia para lidar com alterações de schema.

Não

STRING

LENIENT

Valores válidos listados abaixo. Para mais informações, consulte Configurações de evolução de schema.

• LENIENT (padrão)

• EXCEPTION

• EVOLVE

• TRY_EVOLVE

• IGNORE

schema-operator.rpc-timeout

Tempo limite de espera do SchemaOperator pela conclusão da aplicação de um evento de alteração de schema downstream.

Não

DURATION

3min

-

local-time-zone

Fuso horário local para execução do job.

Não

STRING

Fuso horário do sistema

Esta configuração afeta cálculos relacionados a tempo no módulo transform.

user-defined-function

Funções definidas pelo usuário (UDFs) a serem registradas para o job.

Não

LIST

-

Para mais informações, consulte Funções definidas pelo usuário.

transform.allow.trimming.pk-columns

Permite que regras de transformação reduzam restrições de chave primária upstream.

Não

BOOLEAN

false

A remoção de restrições de PK upstream pode causar a mesclagem de múltiplas entradas de dados, resultando em possível perda de dados. Antes de usar esta configuração, garanta a unicidade da nova PK (caso definida).

transform.decimal.precision.mode

Define a precisão máxima de Decimal utilizada pelo módulo Transform.

Não

STRING

UP_TO_19

Valores válidos:

• UP_TO_19: A precisão máxima do tipo Decimal retornada por expressões é 19. Comportamento padrão no VVR 11.6 e anteriores.

• UP_TO_38: A precisão máxima do tipo Decimal retornada por expressões é 38.