(paimon) branch master updated: [flink][util] MultipleParameterToolAdapter supports merging other parameters (#6016)

[lzljs3620320]

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 9793945b06 [flink][util] MultipleParameterToolAdapter supports merging 
other parameters (#6016)
9793945b06 is described below

commit 9793945b06da0955a0766deac0451ce90239ac19
Author: yuzelin <33053040+yuze...@users.noreply.github.com>
AuthorDate: Sat Aug 2 11:33:55 2025 +0800

    [flink][util] MultipleParameterToolAdapter supports merging other 
parameters (#6016)
---
 .../apache/paimon/flink/action/MultipleParameterToolAdapter.java  | 8 ++++++++
 .../apache/paimon/flink/action/MultipleParameterToolAdapter.java  | 8 ++++++++
 2 files changed, 16 insertions(+)

diff --git 
a/paimon-flink/paimon-flink1-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
 
b/paimon-flink/paimon-flink1-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
index aee2bad58b..c08cff88e1 100644
--- 
a/paimon-flink/paimon-flink1-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
+++ 
b/paimon-flink/paimon-flink1-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
@@ -31,6 +31,10 @@ public class MultipleParameterToolAdapter {
         this.params = MultipleParameterTool.fromArgs(args);
     }
 
+    private MultipleParameterToolAdapter(MultipleParameterTool params) {
+        this.params = params;
+    }
+
     public boolean has(String key) {
         return params.has(key) || params.has(fallback(key));
     }
@@ -59,4 +63,8 @@ public class MultipleParameterToolAdapter {
         }
         return value;
     }
+
+    public MultipleParameterToolAdapter mergeWith(MultipleParameterToolAdapter 
other) {
+        return new 
MultipleParameterToolAdapter(this.params.mergeWith(other.params));
+    }
 }
diff --git 
a/paimon-flink/paimon-flink2-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
 
b/paimon-flink/paimon-flink2-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
index 4fb80d63b5..b545748195 100644
--- 
a/paimon-flink/paimon-flink2-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
+++ 
b/paimon-flink/paimon-flink2-common/src/main/java/org/apache/paimon/flink/action/MultipleParameterToolAdapter.java
@@ -31,6 +31,10 @@ public class MultipleParameterToolAdapter {
         this.params = MultipleParameterTool.fromArgs(args);
     }
 
+    private MultipleParameterToolAdapter(MultipleParameterTool params) {
+        this.params = params;
+    }
+
     public boolean has(String key) {
         return params.has(key) || params.has(fallback(key));
     }
@@ -59,4 +63,8 @@ public class MultipleParameterToolAdapter {
         }
         return value;
     }
+
+    public MultipleParameterToolAdapter mergeWith(MultipleParameterToolAdapter 
other) {
+        return new 
MultipleParameterToolAdapter(this.params.mergeWith(other.params));
+    }
 }