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;