fix

askwang · Dec 18, 2024 · 3244a12 · 3244a12
1 parent a6aa2be
commit 3244a12
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...imon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsAction.java b/...imon-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;