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

Co-authored-by: StrikeW <[email protected]> Co-authored-by: lmatz <[email protected]>
risingwavelabs · Nov 19, 2024 · 966298e · 966298e
1 parent 5ffc814
commit 966298e
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
@@ -664,8 +664,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":