This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 974834d54 [cdc] supports configuring parameter
scan.incremental.close-idle-reader.enabled (#3122)
974834d54 is described below
commit 974834d54b625ec0cbac1f73d199394066fb31b2
Author: zhourui999 <[email protected]>
AuthorDate: Fri Aug 16 13:33:43 2024 +0800
[cdc] supports configuring parameter
scan.incremental.close-idle-reader.enabled (#3122)
---
.../org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java
index 929529a63..309471cbb 100644
---
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java
+++
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java
@@ -177,6 +177,10 @@ public class MySqlActionUtils {
.getOptional(MySqlSourceOptions.HEARTBEAT_INTERVAL)
.ifPresent(sourceBuilder::heartbeatInterval);
+ mySqlConfig
+
.getOptional(MySqlSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED)
+ .ifPresent(sourceBuilder::closeIdleReaders);
+
String startupMode =
mySqlConfig.get(MySqlSourceOptions.SCAN_STARTUP_MODE);
// see
//
https://github.com/apache/flink-cdc/blob/master/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java#L197
