[incubator-paimon] branch master updated: [catalog] Use `tableExists` for flink and spark catalog (#888)

[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 827b94219 [catalog] Use `tableExists` for flink and spark catalog 
(#888)
827b94219 is described below

commit 827b9421916467d4d5123fbe2fdfb0aa5aaf4c3a
Author: Guangdong Liu <liug...@gmail.com>
AuthorDate: Thu Apr 13 09:44:49 2023 +0800

    [catalog] Use `tableExists` for flink and spark catalog (#888)
---
 .../src/main/java/org/apache/paimon/flink/FlinkCatalog.java      | 7 +------
 .../src/main/java/org/apache/paimon/spark/SparkCatalogBase.java  | 9 +++++++++
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
index 01dc89d50..091f08f2b 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
@@ -174,12 +174,7 @@ public class FlinkCatalog extends AbstractCatalog {
 
     @Override
     public boolean tableExists(ObjectPath tablePath) throws CatalogException {
-        try {
-            catalog.getTable(toIdentifier(tablePath));
-            return true;
-        } catch (Catalog.TableNotExistException e) {
-            return false;
-        }
+        return catalog.tableExists(toIdentifier(tablePath));
     }
 
     @Override
diff --git 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalogBase.java
 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalogBase.java
index f1c903ca7..66138b726 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalogBase.java
+++ 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalogBase.java
@@ -212,6 +212,15 @@ public abstract class SparkCatalogBase implements 
TableCatalog, SupportsNamespac
         }
     }
 
+    @Override
+    public boolean tableExists(Identifier ident) {
+        try {
+            return catalog.tableExists(toIdentifier(ident));
+        } catch (NoSuchTableException e) {
+            return false;
+        }
+    }
+
     @Override
     public Table alterTable(Identifier ident, TableChange... changes) throws 
NoSuchTableException {
         List<SchemaChange> schemaChanges =