| commit | 319962ca28598de0f23657ed37986597e3eaef9a | [log] [tgz] |
|---|---|---|
| author | Ken Geis <kgeis@berkeley.edu> | Tue Sep 17 16:58:02 2024 -0700 |
| committer | Rui Fan <1996fanrui@gmail.com> | Thu Jun 05 09:46:35 2025 +0200 |
| tree | 9542769d3486c14f8d4c6f9eb0380d94234cfafd | |
| parent | dd89235981af1b64755225c1d49e9f6dc1cf637b [diff] |
[FLINK-36303][JDBC/postgres] fix PostgreSQL minimum timestamp precision
diff --git a/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java b/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java index e087d61..f42ba48 100644 --- a/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java +++ b/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java
@@ -39,7 +39,7 @@ // Define MAX/MIN precision of TIMESTAMP type according to PostgreSQL docs: // https://www.postgresql.org/docs/12/datatype-datetime.html private static final int MAX_TIMESTAMP_PRECISION = 6; - private static final int MIN_TIMESTAMP_PRECISION = 1; + private static final int MIN_TIMESTAMP_PRECISION = 0; // Define MAX/MIN precision of DECIMAL type according to PostgreSQL docs: // https://www.postgresql.org/docs/12/datatype-numeric.html#DATATYPE-NUMERIC-DECIMAL