From 3244a12abe304627600edfb9acafa692613603e1 Mon Sep 17 00:00:00 2001 From: Askwang <135721692+Askwang@users.noreply.github.com> Date: Wed, 18 Dec 2024 21:44:27 +0800 Subject: [PATCH] fix --- .../apache/paimon/flink/action/ExpireSnapshotsAction.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsAction.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsAction.java index 7293497da16a..6822f6a7a9ad 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsAction.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsAction.java @@ -44,8 +44,9 @@ public ExpireSnapshotsAction( String olderThan, Integer maxDeletes, String options) { - super(warehouse, catalogConfig); - this.identifier = identifier; + super(catalogConfig); + this.database = database; + this.table = table; this.retainMax = retainMax; this.retainMin = retainMin; this.olderThan = olderThan;