You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2024/08/16 05:33:50 UTC
(paimon) branch master updated: [cdc] supports configuring parameter scan.incremental.close-idle-reader.enabled (#3122)
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 <40...@users.noreply.github.com>
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