Skip to content

Commit 9197b9b

Browse files
author
wangjunbo
committed
rename configuration
1 parent 432f663 commit 9197b9b

File tree

12 files changed

+31
-31
lines changed

12 files changed

+31
-31
lines changed

‎docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -390,7 +390,7 @@ Flink SQL> SELECT * FROM orders;
390390
</td>
391391
</tr>
392392
<tr>
393-
<td>scan.incremental.snapshot.assign-ending-first.enabled</td>
393+
<td>scan.incremental.snapshot.assign-ending-chunk-first.enabled</td>
394394
<td>optional</td>
395395
<td style="word-wrap: break-word;">false</td>
396396
<td>Boolean</td>

‎docs/content.zh/docs/connectors/pipeline-connectors/mysql.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,7 @@ pipeline:
313313
<td>是否将TINYINT(1)类型当做Boolean类型处理，默认true。</td>
314314
</tr>
315315
<tr>
316-
<td>scan.incremental.snapshot.assign-ending-first.enabled</td>
316+
<td>scan.incremental.snapshot.assign-ending-chunk-first.enabled</td>
317317
<td>optional</td>
318318
<td style="word-wrap: break-word;">false</td>
319319
<td>Boolean</td>

‎docs/content/docs/connectors/flink-sources/mysql-cdc.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -416,7 +416,7 @@ During a snapshot operation, the connector will query each included table to pro
416416
</td>
417417
</tr>
418418
<tr>
419-
<td>scan.incremental.snapshot.assign-ending-first.enabled</td>
419+
<td>scan.incremental.snapshot.assign-ending-chunk-first.enabled</td>
420420
<td>optional</td>
421421
<td style="word-wrap: break-word;">false</td>
422422
<td>Boolean</td>

‎docs/content/docs/connectors/pipeline-connectors/mysql.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -333,7 +333,7 @@ pipeline:
333333
</td>
334334
</tr>
335335
<tr>
336-
<td>scan.incremental.snapshot.assign-ending-first.enabled</td>
336+
<td>scan.incremental.snapshot.assign-ending-chunk-first.enabled</td>
337337
<td>optional</td>
338338
<td style="word-wrap: break-word;">false</td>
339339
<td>Boolean</td>

‎flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@
7676
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.PORT;
7777
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED;
7878
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED;
79-
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST;
79+
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST;
8080
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN;
8181
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE;
8282
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED;
@@ -152,7 +152,7 @@ public DataSource createDataSource(Context context) {
152152
boolean isParsingOnLineSchemaChanges = config.get(PARSE_ONLINE_SCHEMA_CHANGES);
153153
boolean useLegacyJsonFormat = config.get(USE_LEGACY_JSON_FORMAT);
154154
boolean isAssignEndingChunkFirst =
155-
config.get(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST);
155+
config.get(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST);
156156

157157
validateIntegerOption(SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE, splitSize, 1);
158158
validateIntegerOption(CHUNK_META_GROUP_SIZE, splitMetaGroupSize, 1);
@@ -341,7 +341,7 @@ public Set<ConfigOption<?>> optionalOptions() {
341341
options.add(USE_LEGACY_JSON_FORMAT);
342342
options.add(TREAT_TINYINT1_AS_BOOLEAN_ENABLED);
343343
options.add(PARSE_ONLINE_SCHEMA_CHANGES);
344-
options.add(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST);
344+
options.add(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST);
345345
return options;
346346
}
347347

‎flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -315,8 +315,8 @@ public class MySqlDataSourceOptions {
315315
"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.");
316316

317317
@Experimental
318-
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST =
319-
ConfigOptions.key("scan.incremental.snapshot.assign-ending-first.enabled")
318+
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST =
319+
ConfigOptions.key("scan.incremental.snapshot.assign-ending-chunk-first.enabled")
320320
.booleanType()
321321
.defaultValue(false)
322322
.withDescription(

‎flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceFactoryTest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@
4141
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.PASSWORD;
4242
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.PORT;
4343
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED;
44-
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST;
44+
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST;
4545
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN;
4646
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.TABLES;
4747
import static org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions.TABLES_EXCLUDE;
@@ -261,7 +261,7 @@ public void testOptionalOption() {
261261
// optional option
262262
options.put(TREAT_TINYINT1_AS_BOOLEAN_ENABLED.key(), "false");
263263
options.put(PARSE_ONLINE_SCHEMA_CHANGES.key(), "false");
264-
options.put(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.key(), "false");
264+
options.put(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.key(), "false");
265265

266266
Factory.Context context = new MockContext(Configuration.fromMap(options));
267267
MySqlDataSourceFactory factory = new MySqlDataSourceFactory();
@@ -270,7 +270,7 @@ public void testOptionalOption() {
270270
assertThat(factory.optionalOptions().contains(PARSE_ONLINE_SCHEMA_CHANGES)).isEqualTo(true);
271271
assertThat(
272272
factory.optionalOptions()
273-
.contains(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST))
273+
.contains(SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST))
274274
.isEqualTo(true);
275275

276276
MySqlDataSource dataSource = (MySqlDataSource) factory.createDataSource(context);

‎flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public abstract class JdbcSourceConfigFactory implements Factory<JdbcSourceConfi
6161
protected boolean scanNewlyAddedTableEnabled =
6262
JdbcSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED.defaultValue();
6363
protected boolean assignEndingChunkFirst =
64-
JdbcSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST.defaultValue();
64+
JdbcSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST.defaultValue();
6565

6666
/** Integer port number of the database server. */
6767
public JdbcSourceConfigFactory hostname(String hostname) {

‎flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/SourceOptions.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -139,8 +139,8 @@ public class SourceOptions {
139139
"Whether capture the newly added tables when restoring from a savepoint/checkpoint or not, by default is false.");
140140

141141
@Experimental
142-
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST =
143-
ConfigOptions.key("scan.incremental.snapshot.assign-ending-first.enabled")
142+
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST =
143+
ConfigOptions.key("scan.incremental.snapshot.assign-ending-chunk-first.enabled")
144144
.booleanType()
145145
.defaultValue(false)
146146
.withDescription(

‎flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -280,8 +280,8 @@ public class MySqlSourceOptions {
280280
"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.");
281281

282282
@Experimental
283-
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_FIRST =
284-
ConfigOptions.key("scan.incremental.snapshot.assign-ending-first.enabled")
283+
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ASSIGN_ENDING_CHUNK_FIRST =
284+
ConfigOptions.key("scan.incremental.snapshot.assign-ending-chunk-first.enabled")
285285
.booleanType()
286286
.defaultValue(false)
287287
.withDescription(

0 commit comments

Comments
 (0)