thswlsqls opened a new pull request, #8609: URL: https://github.com/apache/paimon/pull/8609
### Purpose fix #8604 - The int32 branch of `PostgresRecordParser.extractFieldType()` handled only `io.debezium.time.Date` and fell through to `INT()`, missing the sibling `io.debezium.time.Time` logical type (int32, millis-of-day) that Debezium emits for PostgreSQL `time(0..3)` in the default adaptive mode. - This disagreed with the JDBC bootstrap path (`PostgresTypeUtils` maps `time` to `TIME(scale)`), crashing the sync on the first record. Now maps `io.debezium.time.Time` to `TIME(3)`. - Symmetric with the int64 `Timestamp` fix from #8222; `time(4..6)` (`MicroTime`, int64) was already handled. ### Tests - Added `PostgresRecordParserTest#testTimeMillisFieldMapsToTime3` (int32 `Time` maps to `TIME(3)`) and `#testPlainInt32FieldMapsToInt` (negative: plain int32 stays `INT`). - `mvn -pl paimon-flink/paimon-flink-cdc -Pflink1 clean install` — `PostgresRecordParserTest` 5 tests passed (checkstyle/spotless/rat gates green). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
