(incubator-paimon) branch master updated: [flink] remove schemaFileExists check for showing tables when using HiveCatalog (#2537)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 3f41911c2 [flink] remove schemaFileExists check for showing tables  
when using HiveCatalog (#2537)
3f41911c2 is described below

commit 3f41911c220b59fdadcb47caf9370685905800d6
Author: wgcn <1026688...@qq.com>
AuthorDate: Wed Dec 20 18:01:24 2023 +0800

    [flink] remove schemaFileExists check for showing tables  when using 
HiveCatalog (#2537)
---
 .../src/main/java/org/apache/paimon/hive/HiveCatalog.java    |  4 +---
 .../java/org/apache/paimon/hive/HiveCatalogITCaseBase.java   | 12 ------------
 2 files changed, 1 insertion(+), 15 deletions(-)

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 ff9707f20..f7cfc7614 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
@@ -252,9 +252,7 @@ public class HiveCatalog extends AbstractCatalog {
                     .filter(
                             tableName -> {
                                 Identifier identifier = new 
Identifier(databaseName, tableName);
-                                // the environment here may not be able to 
access non-paimon
-                                // tables, so we just check the schema file 
first
-                                return schemaFileExists(identifier) && 
tableExists(identifier);
+                                return tableExists(identifier);
                             })
                     .collect(Collectors.toList());
         } catch (TException e) {
diff --git 
a/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
 
b/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
index 022a455a1..93cd93c04 100644
--- 
a/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
+++ 
b/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
@@ -23,7 +23,6 @@ import org.apache.paimon.catalog.CatalogLock;
 import org.apache.paimon.catalog.Identifier;
 import org.apache.paimon.flink.DataCatalogTable;
 import org.apache.paimon.flink.FlinkCatalog;
-import org.apache.paimon.fs.local.LocalFileIO;
 import org.apache.paimon.hive.annotation.Minio;
 import org.apache.paimon.hive.runner.PaimonEmbeddedHiveRunner;
 import org.apache.paimon.s3.MinioTestContainer;
@@ -754,17 +753,6 @@ public abstract class HiveCatalogITCaseBase {
                                 "[A, C]"));
     }
 
-    @Test
-    public void testQuickPathInShowTables() throws Exception {
-        collect("CREATE TABLE t ( a INT, b STRING )");
-        List<Row> tables = collect("SHOW TABLES");
-        assertThat(tables.toString()).isEqualTo("[+I[t]]");
-
-        new LocalFileIO().delete(new org.apache.paimon.fs.Path(path, 
"test_db.db/t"), true);
-        tables = collect("SHOW TABLES");
-        assertThat(tables.toString()).isEqualTo("[]");
-    }
-
     @Test
     public void testCatalogOptionsInheritAndOverride() throws Exception {
         tEnv.executeSql(