From 9197b9bdae49944cf0d25059ffe3e6211aed34e2 Mon Sep 17 00:00:00 2001 From: wangjunbo Date: Fri, 7 Feb 2025 11:45:36 +0800 Subject: [PATCH] rename configuration --- .../connectors/flink-sources/mysql-cdc.md | 2 +- .../connectors/pipeline-connectors/mysql.md | 2 +- .../connectors/flink-sources/mysql-cdc.md | 2 +- .../connectors/pipeline-connectors/mysql.md | 2 +- .../mysql/factory/MySqlDataSourceFactory.java | 6 ++--- .../mysql/source/MySqlDataSourceOptions.java | 4 ++-- .../source/MySqlDataSourceFactoryTest.java | 6 ++--- .../base/config/JdbcSourceConfigFactory.java | 2 +- .../base/options/SourceOptions.java | 4 ++-- .../source/config/MySqlSourceOptions.java | 4 ++-- .../mysql/table/MySqlTableSourceFactory.java | 4 ++-- .../table/MySqlTableSourceFactoryTest.java | 24 +++++++++---------- 12 files changed, 31 insertions(+), 31 deletions(-) diff --git a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md index 83e740674bb..a128aa8237c 100644 --- a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md +++ b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md @@ -390,7 +390,7 @@ Flink SQL> SELECT * FROM orders; - scan.incremental.snapshot.assign-ending-first.enabled + scan.incremental.snapshot.assign-ending-chunk-first.enabled optional false Boolean diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md index f2f17072b00..1d55107463a 100644 --- a/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md +++ b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md @@ -313,7 +313,7 @@ pipeline: 是否将TINYINT(1)类型当做Boolean类型处理，默认true。 - scan.incremental.snapshot.assign-ending-first.enabled + scan.incremental.snapshot.assign-ending-chunk-first.enabled optional false Boolean diff --git a/docs/content/docs/connectors/flink-sources/mysql-cdc.md b/docs/content/docs/connectors/flink-sources/mysql-cdc.md index 1b343b19bde..9cdbbe0435f 100644 --- a/docs/content/docs/connectors/flink-sources/mysql-cdc.md +++ b/docs/content/docs/connectors/flink-sources/mysql-cdc.md @@ -416,7 +416,7 @@ During a snapshot operation, the connector will query each included table to pro - scan.incremental.snapshot.assign-ending-first.enabled + scan.incremental.snapshot.assign-ending-chunk-first.enabled optional false Boolean diff --git a/docs/content/docs/connectors/pipeline-connectors/mysql.md b/docs/content/docs/connectors/pipeline-connectors/mysql.md index d04a0366860..6950c6510bc 100644 --- a/docs/content/docs/connectors/pipeline-connectors/mysql.md +++ b/docs/content/docs/connectors/pipeline-connectors/mysql.md @@ -333,7 +333,7 @@ pipeline: - scan.incremental.snapshot.assign-ending-first.enabled + scan.incremental.snapshot.assign-ending-chunk-first.enabled optional false Boolean diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java index 1b7a73e73a6..b6c48167474 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java @@ -76,7 +76,7 @@ import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.PORT; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED; -import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST; +import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED; @@ -152,7 +152,7 @@ public DataSource createDataSource(Context context) { boolean isParsingOnLineSchemaChanges = config.get(PARSE_ONLINE_SCHEMA_CHANGES); boolean useLegacyJsonFormat = config.get(USE_LEGACY_JSON_FORMAT); boolean isAssignEndingChunkFirst = - config.get(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST); + config.get(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST); validateIntegerOption(SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE, splitSize, 1); validateIntegerOption(CHUNK_META_GROUP_SIZE, splitMetaGroupSize, 1); @@ -341,7 +341,7 @@ public Set> optionalOptions() { options.add(USE_LEGACY_JSON_FORMAT); options.add(TREAT_TINYINT1_AS_BOOLEAN_ENABLED); options.add(PARSE_ONLINE_SCHEMA_CHANGES); - options.add(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST); + options.add(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST); return options; } diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java index 9450f2c053b..a9921b1ab1b 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java @@ -315,8 +315,8 @@ public class MySqlDataSourceOptions { "Whether to use legacy json format. The default value is true, which means there is no whitespace before value and after comma in json format."); @Experimental - public static final ConfigOption SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST = - ConfigOptions.key("scan.incremental.snapshot.assign-ending-first.enabled") + public static final ConfigOption SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST = + ConfigOptions.key("scan.incremental.snapshot.assign-ending-chunk-first.enabled") .booleanType() .defaultValue(false) .withDescription( diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceFactoryTest.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceFactoryTest.java index 14cc31498ba..670e8d7ff92 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceFactoryTest.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceFactoryTest.java @@ -41,7 +41,7 @@ import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.PASSWORD; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.PORT; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED; -import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST; +import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.TABLES; import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.TABLES_EXCLUDE; @@ -261,7 +261,7 @@ public void testOptionalOption() { // optional option options.put(TREAT_TINYINT1_AS_BOOLEAN_ENABLED.key(), "false"); options.put(PARSE_ONLINE_SCHEMA_CHANGES.key(), "false"); - options.put(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.key(), "false"); + options.put(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.key(), "false"); Factory.Context context = new MockContext(Configuration.fromMap(options)); MySqlDataSourceFactory factory = new MySqlDataSourceFactory(); @@ -270,7 +270,7 @@ public void testOptionalOption() { assertThat(factory.optionalOptions().contains(PARSE_ONLINE_SCHEMA_CHANGES)).isEqualTo(true); assertThat( factory.optionalOptions() - .contains(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST)) + .contains(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST)) .isEqualTo(true); MySqlDataSource dataSource = (MySqlDataSource) factory.createDataSource(context); diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java index dfb5107cf66..5ff9211d726 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java @@ -61,7 +61,7 @@ public abstract class JdbcSourceConfigFactory implements Factory SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST = - ConfigOptions.key("scan.incremental.snapshot.assign-ending-first.enabled") + public static final ConfigOption SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST = + ConfigOptions.key("scan.incremental.snapshot.assign-ending-chunk-first.enabled") .booleanType() .defaultValue(false) .withDescription( diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java index cc87daae9b1..a21f790b9b8 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java @@ -280,8 +280,8 @@ public class MySqlSourceOptions { "Whether to use legacy json format. The default value is true, which means there is no whitespace before value and after comma in json format."); @Experimental - public static final ConfigOption SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST = - ConfigOptions.key("scan.incremental.snapshot.assign-ending-first.enabled") + public static final ConfigOption SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST = + ConfigOptions.key("scan.incremental.snapshot.assign-ending-chunk-first.enabled") .booleanType() .defaultValue(false) .withDescription( diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java index 8d1e20248a3..a7ccb40550e 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java @@ -106,7 +106,7 @@ public DynamicTableSource createDynamicTableSource(Context context) { config.get(MySqlSourceOptions.PARSE_ONLINE_SCHEMA_CHANGES); boolean useLegacyJsonFormat = config.get(MySqlSourceOptions.USE_LEGACY_JSON_FORMAT); boolean assignEndingChunkFirst = - config.get(MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST); + config.get(MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST); if (enableParallelRead) { validatePrimaryKeyIfEnableParallel(physicalSchema, chunkKeyColumn); @@ -201,7 +201,7 @@ public Set> optionalOptions() { options.add(MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP); options.add(MySqlSourceOptions.PARSE_ONLINE_SCHEMA_CHANGES); options.add(MySqlSourceOptions.USE_LEGACY_JSON_FORMAT); - options.add(MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST); + options.add(MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST); return options; } diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactoryTest.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactoryTest.java index 16f4317337f..29b8f5d5bee 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactoryTest.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactoryTest.java @@ -52,7 +52,7 @@ import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.CONNECT_TIMEOUT; import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.HEARTBEAT_INTERVAL; import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.PARSE_ONLINE_SCHEMA_CHANGES; -import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST; +import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST; import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP; import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE; import static org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ENABLED; @@ -133,7 +133,7 @@ public void testCommonProperties() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -182,7 +182,7 @@ public void testEnableParallelReadSource() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -227,7 +227,7 @@ public void testEnableParallelReadSourceWithSingleServerId() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -270,7 +270,7 @@ public void testEnableParallelReadSourceLatestOffset() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -330,7 +330,7 @@ public void testOptionalProperties() { true, PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), true, - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); assertTrue(actualSource instanceof MySqlTableSource); MySqlTableSource actualMySqlTableSource = (MySqlTableSource) actualSource; @@ -387,7 +387,7 @@ public void testStartupFromSpecificOffset() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -428,7 +428,7 @@ public void testStartupFromInitial() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -470,7 +470,7 @@ public void testStartupFromEarliestOffset() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -513,7 +513,7 @@ public void testStartupFromSpecificTimestamp() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -554,7 +554,7 @@ public void testStartupFromLatestOffset() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); assertEquals(expectedSource, actualSource); } @@ -600,7 +600,7 @@ public void testMetadataColumns() { SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP.defaultValue(), PARSE_ONLINE_SCHEMA_CHANGES.defaultValue(), USE_LEGACY_JSON_FORMAT.defaultValue(), - SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue()); + SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue()); expectedSource.producedDataType = SCHEMA_WITH_METADATA.toSourceRowDataType(); expectedSource.metadataKeys = Arrays.asList("op_ts", "database_name");