This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 775af1a [Improvement] Add MySQLSource Options (#154) (#155)
775af1a is described below
commit 775af1ad53a9601ac85652364c361a2332feafa2
Author: cygnusdark <[email protected]>
AuthorDate: Thu Aug 17 10:06:06 2023 +0800
[Improvement] Add MySQLSource Options (#154) (#155)
---
.../org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
index ac047e4..1bafd2b 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
@@ -133,6 +133,12 @@ public class MysqlDatabaseSync extends DatabaseSync {
config
.getOptional(MySqlSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED)
.ifPresent(sourceBuilder::scanNewlyAddedTableEnabled);
+ config
+
.getOptional(MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE)
+ .ifPresent(sourceBuilder::splitSize);
+ config
+
.getOptional(MySqlSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED)
+ .ifPresent(sourceBuilder::closeIdleReaders);
String startupMode = config.get(MySqlSourceOptions.SCAN_STARTUP_MODE);
if ("initial".equalsIgnoreCase(startupMode)) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
