From 38d6bc333c628558087e255584a289f8ead39c2a Mon Sep 17 00:00:00 2001
From: "chun.ji" <chun.ji@trip.com>
Date: Tue, 30 Jul 2024 15:10:41 +0800
Subject: [PATCH] [cdc] fix `float` type convert error in
 DebeziumSchemaUtils#fromDebeziumType (apache#3846)

---
 .../flink/action/cdc/format/debezium/DebeziumSchemaUtils.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java
index 1aab6653d4d4..e61b33d0ed1e 100644
--- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java
+++ b/paimon-flink/paimon-flink-cdc/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();