remove debezium double type

sunxiaojian · Jan 30, 2024 · d09c294 · d09c294
1 parent 15f8c9a
commit d09c294
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 6 deletions.
diff --git a/...src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java b/...src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java
@@ -215,9 +215,8 @@ private static DataType fromDebeziumType(String dbzType) {
             case "int64":
                 return DataTypes.BIGINT();
             case "float32":
-            case "float64":
                 return DataTypes.FLOAT();
-            case "double":
+            case "float64":
                 return DataTypes.DOUBLE();
             case "boolean":
                 return DataTypes.BOOLEAN();

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
@@ -93,13 +93,13 @@ public void testKafkaBuildSchemaWithDelete() throws Exception {
     }
 
     @Test
-    @Timeout(60)
+    @Timeout(120)
     public void testSchemaIncludeRecord1() throws Exception {
         testSchemaIncludeRecord(DEBEZIUM);
     }
 
     @Test
-    @Timeout(60)
+    @Timeout(120)
     public void testAllTypesWithSchema() throws Exception {
         testAllTypesWithSchemaImpl(DEBEZIUM);
     }