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 a5325a3ed8 [flink][action] rename some argument for avoiding ambiguity
(#5368)
a5325a3ed8 is described below
commit a5325a3ed82d3009864dca658fd3d3e748fab4a2
Author: LsomeYeah <[email protected]>
AuthorDate: Fri Mar 28 15:21:00 2025 +0800
[flink][action] rename some argument for avoiding ambiguity (#5368)
---
.../java/org/apache/paimon/flink/action/ExpireChangelogsAction.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsAction.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsAction.java
index 9625b24202..bd0389fdfb 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsAction.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsAction.java
@@ -54,9 +54,9 @@ public class ExpireChangelogsAction extends ActionBase {
}
public void run() throws Exception {
- ExpireChangelogsProcedure expireSnapshotsProcedure = new
ExpireChangelogsProcedure();
- expireSnapshotsProcedure.withCatalog(catalog);
- expireSnapshotsProcedure.call(
+ ExpireChangelogsProcedure expireChangelogsProcedure = new
ExpireChangelogsProcedure();
+ expireChangelogsProcedure.withCatalog(catalog);
+ expireChangelogsProcedure.call(
new DefaultProcedureContext(env),
database + "." + table,
retainMax,
