[cdc] fix float type convert error in DebeziumSchemaUtils#fromDebez…

…iumType (#3847)
apache · Jul 30, 2024 · 1e98ba8 · 1e98ba8
1 parent 76d2520
commit 1e98ba8
Showing 1 changed file with 1 addition and 0 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
@@ -225,6 +225,7 @@ private static DataType fromDebeziumType(String dbzType) {
                 return DataTypes.INT();
             case "int64":
                 return DataTypes.BIGINT();
+            case "float":
             case "float32":
             case "float64":
                 return DataTypes.FLOAT();