From 966298e9ff76a90b8908ecd9e625c0373711c4bb Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" <41898282+github-actions[bot]@users.noreply.github.com> Date: Tue, 19 Nov 2024 15:14:44 +0800 Subject: [PATCH] fix(pg-cdc): fix real/float data type mapping (#19300) (#19314) Co-authored-by: StrikeW Co-authored-by: lmatz --- .../risingwave/connector/source/common/PostgresValidator.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/PostgresValidator.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/PostgresValidator.java index a58c5088a1039..2199dd6168d62 100644 --- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/PostgresValidator.java +++ b/java/connector-node/risingwave-connector-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":