fixed

apache · Apr 18, 2024 · e9005ef · e9005ef
1 parent bbffd11
commit e9005ef
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...est/java/org/apache/paimon/flink/action/cdc/kafka/KafkaDebeziumSyncTableActionITCase.java b/...est/java/org/apache/paimon/flink/action/cdc/kafka/KafkaDebeziumSyncTableActionITCase.java
@@ -133,7 +133,7 @@ public void testMessageWithNullValue() throws Exception {
         KafkaSyncTableAction action =
                 syncTableActionBuilder(kafkaConfig)
                         .withPrimaryKeys("id")
-                        .withTableConfig(getBasicTableConfig())
+                        .withTableConfig(getTableConfig(getBasicTableConfig()))
                         .build();
         runActionWithDefaultEnv(action);
 

diff --git a/...dc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java b/...dc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
@@ -1164,7 +1164,7 @@ public void testOptionsChangeInExistingTable() throws Exception {
         MySqlSyncTableAction action =
                 syncTableActionBuilder(mySqlConfig)
                         .withPrimaryKeys("pk")
-                        .withTableConfig(tableConfig)
+                        .withTableConfig(getTableConfig(tableConfig))
                         .build();
         runActionWithDefaultEnv(action);