Skip to content

Commit 7bbfab0

Browse files
authored
[FLINK-38398][pipeline-connector][postgres] fixed Date convert adapt connect (#4133)
1 parent c6f5481 commit 7bbfab0

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -314,6 +314,10 @@ protected Object convertToFloat(Object dbzObj, Schema schema) {
314314
}
315315

316316
protected Object convertToDate(Object dbzObj, Schema schema) {
317+
if (dbzObj instanceof Date) {
318+
Instant instant = ((Date) dbzObj).toInstant();
319+
return DateData.fromLocalDate(instant.atZone(java.time.ZoneOffset.UTC).toLocalDate());
320+
}
317321
return DateData.fromLocalDate(TemporalConversions.toLocalDate(dbzObj));
318322
}
319323

0 commit comments

Comments
 (0)