From 6a50dcf6c800d89d596b5b27472724754cdd0057 Mon Sep 17 00:00:00 2001 From: Kexiang Wang Date: Fri, 15 Nov 2024 19:03:15 -0500 Subject: [PATCH] tmp --- .../risingwave/connector/source/common/PostgresValidator.java | 1 - 1 file changed, 1 deletion(-) 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 446b50280c706..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 @@ -653,7 +653,6 @@ public void close() throws Exception { private boolean isDataTypeCompatible(String pgDataType, Data.DataType.TypeName typeName) { int val = typeName.getNumber(); - System.out.println("WKXLOG val: " + typeName + " type: " + pgDataType); switch (pgDataType) { case "smallint": return Data.DataType.TypeName.INT16_VALUE <= val