diff --git a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java index a590ede6d2e6..7d396954cf95 100644 --- a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java +++ b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java @@ -442,8 +442,7 @@ protected List listTablesImpl(String databaseName) { try { Identifier identifier = new Identifier(databaseName, t); Table table = getHmsTable(identifier); - if (isPaimonTable(identifier, table) - || (!formatTableDisabled() && isFormatTable(table))) { + if (isPaimonTable(table) || (!formatTableDisabled() && isFormatTable(table))) { result.add(t); } } catch (TableNotExistException ignored) { @@ -478,7 +477,7 @@ public TableSchema getDataTableSchema(Identifier identifier) throws TableNotExis private TableSchema getDataTableSchema(Identifier identifier, Table table) throws TableNotExistException { - if (!isPaimonTable(identifier, table)) { + if (!isPaimonTable(table)) { throw new TableNotExistException(identifier); } @@ -870,7 +869,7 @@ private Table renameHiveTable(Identifier fromTable, Identifier toTable) { protected void alterTableImpl(Identifier identifier, List changes) throws TableNotExistException, ColumnAlreadyExistException, ColumnNotExistException { Table table = getHmsTable(identifier); - if (!isPaimonTable(identifier, table)) { + if (!isPaimonTable(table)) { throw new UnsupportedOperationException("Only data table support alter table."); } @@ -1044,12 +1043,6 @@ public Table getHmsTable(Identifier identifier) throws TableNotExistException { } } - private boolean isPaimonTable(Identifier identifier, Table table) { - return isPaimonTable(table) - && tableExistsInFileSystem( - getTableLocation(identifier, table), identifier.getBranchNameOrDefault()); - } - private static boolean isPaimonTable(Table table) { boolean isPaimonTable = INPUT_FORMAT_CLASS_NAME.equals(table.getSd().getInputFormat())