(flink-cdc) branch master updated: [FLINK-38398][pipeline-connector][postgres] fixed Date convert adapt connect (#4133)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 7bbfab049 [FLINK-38398][pipeline-connector][postgres] fixed Date 
convert adapt connect (#4133)
7bbfab049 is described below

commit 7bbfab049e5246971f766ceeb6ca450aff4a0762
Author: ouyangwulin <mr.art...@gmail.com>
AuthorDate: Mon Sep 22 19:49:26 2025 +0800

    [FLINK-38398][pipeline-connector][postgres] fixed Date convert adapt 
connect (#4133)
---
 .../flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java
index a7c300cd3..c484709ff 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java
@@ -314,6 +314,10 @@ public abstract class DebeziumEventDeserializationSchema 
extends SourceRecordEve
     }
 
     protected Object convertToDate(Object dbzObj, Schema schema) {
+        if (dbzObj instanceof Date) {
+            Instant instant = ((Date) dbzObj).toInstant();
+            return 
DateData.fromLocalDate(instant.atZone(java.time.ZoneOffset.UTC).toLocalDate());
+        }
         return DateData.fromLocalDate(TemporalConversions.toLocalDate(dbzObj));
     }