|
|
|
@ -60,6 +60,7 @@ import java.util.Collections;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.stream.Stream;
|
|
|
|
|
|
|
|
|
|
import static com.ververica.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCHEMA_CHANGE_ENABLED;
|
|
|
|
|
import static com.ververica.cdc.connectors.mysql.testutils.MySqSourceTestUtils.TEST_PASSWORD;
|
|
|
|
|
import static com.ververica.cdc.connectors.mysql.testutils.MySqSourceTestUtils.TEST_USER;
|
|
|
|
|
import static com.ververica.cdc.connectors.mysql.testutils.MySqSourceTestUtils.fetchResults;
|
|
|
|
@ -114,7 +115,7 @@ public class MySqlPipelineITCase extends MySqlSourceTestBase {
|
|
|
|
|
.startupOptions(StartupOptions.initial())
|
|
|
|
|
.serverId(getServerId(env.getParallelism()))
|
|
|
|
|
.serverTimeZone("UTC")
|
|
|
|
|
.includeSchemaChanges(true);
|
|
|
|
|
.includeSchemaChanges(SCHEMA_CHANGE_ENABLED.defaultValue());
|
|
|
|
|
|
|
|
|
|
FlinkSourceProvider sourceProvider =
|
|
|
|
|
(FlinkSourceProvider) new MySqlDataSource(configFactory).getEventSourceProvider();
|
|
|
|
@ -242,7 +243,7 @@ public class MySqlPipelineITCase extends MySqlSourceTestBase {
|
|
|
|
|
.startupOptions(StartupOptions.latest())
|
|
|
|
|
.serverId(getServerId(env.getParallelism()))
|
|
|
|
|
.serverTimeZone("UTC")
|
|
|
|
|
.includeSchemaChanges(true);
|
|
|
|
|
.includeSchemaChanges(SCHEMA_CHANGE_ENABLED.defaultValue());
|
|
|
|
|
|
|
|
|
|
FlinkSourceProvider sourceProvider =
|
|
|
|
|
(FlinkSourceProvider) new MySqlDataSource(configFactory).getEventSourceProvider();
|
|
|
|
|