Realtime Compute for Apache Flink:Flink CDC pipeline module

Paramètre

Description

Obligatoire

Type de données

Valeur par défaut

Remarque

name

Nom de la tâche d'ingestion de données Flink CDC.

Non

STRING

Flink CDC Pipeline Job

-

schema.change.behavior

Stratégie de gestion des modifications de schéma.

Non

STRING

LENIENT

Les valeurs valides sont répertoriées ci-dessous. Pour plus d'informations, consultez Configurations d'évolution du schéma.

• LENIENT (par défaut)

• EXCEPTION

• EVOLVE

• TRY_EVOLVE

• IGNORE

schema-operator.rpc-timeout

Délai d'attente de SchemaOperator pour l'application d'un événement de modification de schéma en aval.

Non

DURATION

3min

Délai d'attente du processus de coordination des modifications de schéma.

local-time-zone

Fuseau horaire local pour l'exécution de la tâche.

Non

STRING

Fuseau horaire du système

Ce paramètre affecte les calculs liés au temps dans le module transform.

user-defined-function

Fonctions définies par l'utilisateur (UDF) à enregistrer pour la tâche.

Non

LIST

-

Pour plus d'informations, consultez Fonctions définies par l'utilisateur.

transform.allow.trimming.pk-columns

Permet aux règles de transformation de réduire les contraintes de clé primaire en amont

Non

BOOLEAN

false

La suppression des contraintes de clé primaire en amont peut entraîner la fusion de plusieurs entrées de données, ce qui risque de provoquer des pertes de données. Avant d'utiliser ce paramètre, assurez-vous de l'unicité de la nouvelle clé primaire (si elle est définie).

transform.decimal.precision.mode

Spécifie la précision décimale maximale utilisée par le module Transform.

Non

STRING

UP_TO_19

Valeurs valides :

• UP_TO_19 : la précision maximale du type Decimal renvoyé par les expressions est de 19. Il s'agit du comportement par défaut dans VVR 11.6 et versions antérieures.

• UP_TO_38 : la précision maximale du type Decimal renvoyé par les expressions est de 38.

sink.partitioning.strategy

Spécifie la stratégie de partitionnement qui distribue les événements de modification de données vers les sous-tâches en aval du sink.

Non

STRING

SINK_DEFINED

Valeurs valides :

• SINK_DEFINED : utilise la stratégie de partitionnement définie par le sink. Il s'agit de la valeur par défaut. Les sinks Paimon, Fluss et MaxCompute prennent uniquement en charge SINK_DEFINED.

• PRIMARY_KEY : partitionne les événements par ID de table et valeur de clé primaire. Les événements ayant la même clé primaire sont acheminés vers la même sous-tâche.

• TABLE_ID : partitionne les événements par ID de table. Tous les événements d'une même table sont acheminés vers la même sous-tâche.