From 4b50c636aadbd2e43452e86979393db5d14cba95 Mon Sep 17 00:00:00 2001 From: Ken Geis Date: Thu, 5 Jun 2025 11:13:13 -0700 Subject: [PATCH 1/2] [FLINK-36303][JDBC/postgres] Update PostgresDialectTest to match PostgresDialect change The expected error message for timestamp precision range needs to match the range in PostgresDialect. --- .../jdbc/postgres/database/dialect/PostgresDialectTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialectTest.java b/flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialectTest.java index 97c454c9b..0ad1fb55f 100644 --- a/flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialectTest.java +++ b/flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialectTest.java @@ -59,7 +59,7 @@ protected List testData() { "The PostgreSQL dialect doesn't support type: VARBINARY(10)."), createTestItem( "TIMESTAMP(9) WITHOUT TIME ZONE", - "The precision of field 'f0' is out of the TIMESTAMP precision range [1, 6] supported by PostgreSQL dialect."), + "The precision of field 'f0' is out of the TIMESTAMP precision range [0, 6] supported by PostgreSQL dialect."), createTestItem("TIMESTAMP_LTZ(3)", "Unsupported type:TIMESTAMP_LTZ(3)")); } From 893f8ab2f2152c9ace771306b0e7c4181a3fb7e1 Mon Sep 17 00:00:00 2001 From: Ken Geis Date: Thu, 5 Jun 2025 21:12:18 -0700 Subject: [PATCH 2/2] align CrateDB test with PostgreSQL Timestamp precision change --- .../jdbc/cratedb/database/dialect/CrateDBDialectTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialectTest.java b/flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialectTest.java index 8b75eb13f..16d0e08b5 100644 --- a/flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialectTest.java +++ b/flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialectTest.java @@ -51,7 +51,7 @@ protected List testData() { createTestItem("BINARY", "The CrateDB dialect doesn't support type: BINARY(1)."), createTestItem( "TIMESTAMP(9) WITHOUT TIME ZONE", - "The precision of field 'f0' is out of the TIMESTAMP precision range [1, 6] supported by CrateDB dialect."), + "The precision of field 'f0' is out of the TIMESTAMP precision range [0, 6] supported by CrateDB dialect."), createTestItem("TIMESTAMP_LTZ(3)", "Unsupported type:TIMESTAMP_LTZ(3)")); } }