Skip to content

Commit 95670f6

Browse files
committed
fixed pg sql time zone error.
1 parent 6cc633c commit 95670f6

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresFullTypesITCase.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -264,7 +264,7 @@ public void testTimeTypesWithTemporalModeAdaptive() throws Exception {
264264
.tableList("inventory.time_types")
265265
.startupOptions(StartupOptions.initial())
266266
.debeziumProperties(debeziumProps)
267-
.serverTimeZone("UTC");
267+
.serverTimeZone("UTC+8");
268268
configFactory.database(POSTGRES_CONTAINER.getDatabaseName());
269269
configFactory.slotName(slotName);
270270
configFactory.decodingPluginName("pgoutput");
@@ -298,6 +298,9 @@ public void testTimeTypesWithTemporalModeAdaptive() throws Exception {
298298

299299
List<Event> snapshotResults = fetchResultsAndCreateTableEvent(events, 1).f0;
300300
RecordData snapshotRecord = ((DataChangeEvent) snapshotResults.get(0)).after();
301+
;
302+
303+
Object[] xx = recordFields(snapshotRecord, COMMON_TYPES);
301304
Assertions.assertThat(recordFields(snapshotRecord, TIME_TYPES_WITH_ADAPTIVE))
302305
.isEqualTo(expectedSnapshot);
303306
}

0 commit comments

Comments
 (0)