decimal-no-change test

JackeyLee007 · Dec 30, 2024 · dce4cf2 · dce4cf2
1 parent 6a36699
commit dce4cf2
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...c/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java b/...c/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java
@@ -49,8 +49,7 @@
 import static org.apache.flink.streaming.connectors.kafka.table.KafkaConnectorOptions.TOPIC;
 import static org.apache.flink.streaming.connectors.kafka.table.KafkaConnectorOptions.TOPIC_PATTERN;
 import static org.apache.flink.streaming.connectors.kafka.table.KafkaConnectorOptions.VALUE_FORMAT;
-import static org.apache.paimon.flink.action.cdc.TypeMapping.TypeMappingMode.NO_CHANGE;
-import static org.apache.paimon.flink.action.cdc.TypeMapping.TypeMappingMode.TO_STRING;
+import static org.apache.paimon.flink.action.cdc.TypeMapping.TypeMappingMode.*;
 import static org.apache.paimon.testutils.assertj.PaimonAssertions.anyCauseMatches;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
@@ -1200,7 +1199,7 @@ public void testDeciamlNoChange() throws Exception {
         KafkaSyncTableAction action =
                 syncTableActionBuilder(kafkaConfig)
                         .withTableConfig(getBasicTableConfig())
-                        .withTypeMappingModes(NO_CHANGE.configString())
+                        .withTypeMappingModes(DECIMAL_NO_CHANGE.configString())
                         .build();
         runActionWithDefaultEnv(action);