fix(pg-cdc): fix real/float data type mapping (#19300) (#19315)

Co-authored-by: StrikeW <wangsiyuanse@gmail.com> Co-authored-by: lmatz <lmatz823@gmail.com>
risingwavelabs · Nov 8, 2024 · 016e813 · 016e813
1 parent 2ad0887
commit 016e813
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ector-service/src/main/java/com/risingwave/connector/source/common/PostgresValidator.java b/...ector-service/src/main/java/com/risingwave/connector/source/common/PostgresValidator.java
@@ -553,8 +553,7 @@ private boolean isDataTypeCompatible(String pgDataType, Data.DataType.TypeName t
                 return val == Data.DataType.TypeName.INT64_VALUE;
             case "float":
             case "real":
-                return val == Data.DataType.TypeName.FLOAT_VALUE
-                        || val == Data.DataType.TypeName.DOUBLE_VALUE;
+                return val == Data.DataType.TypeName.FLOAT_VALUE;
             case "boolean":
                 return val == Data.DataType.TypeName.BOOLEAN_VALUE;
             case "double":