diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java b/paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java index 774cb9de31b5e..5f24d5cf85351 100644 --- a/paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java +++ b/paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java @@ -140,6 +140,21 @@ public void dropPartition(Identifier identifier, Map partitions) wrapped.dropPartition(identifier, partitions); } + @Override + public void repairCatalog() { + wrapped.repairCatalog(); + } + + @Override + public void repairDatabase(String databaseName) { + wrapped.repairDatabase(databaseName); + } + + @Override + public void repairTable(Identifier identifier) throws TableNotExistException { + wrapped.repairTable(identifier); + } + @Override public void close() throws Exception { wrapped.close();