From 246e4013e59a5191e21d8a0fb3af99495bad4588 Mon Sep 17 00:00:00 2001 From: zhaomin Date: Mon, 14 Aug 2023 15:44:30 +0800 Subject: [PATCH] [test][mysql] Provide the server-time-zone setting in MySqlSourceExampleTest#testConsumingAllEvents (#2364) (cherry picked from commit a3ddc488d5374841bc25a00d12ca802f47cc5032) --- .../cdc/connectors/mysql/source/MySqlSourceExampleTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceExampleTest.java b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceExampleTest.java index d891b0891..1d145e276 100644 --- a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceExampleTest.java +++ b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceExampleTest.java @@ -44,6 +44,7 @@ public class MySqlSourceExampleTest extends MySqlSourceTestBase { .password(inventoryDatabase.getPassword()) .serverId("5401-5404") .deserializer(new JsonDebeziumDeserializationSchema()) + .serverTimeZone("UTC") .includeSchemaChanges(true) // output the schema changes as well .build();