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

gaojun2048 pushed a commit to branch apache_240124_default_tablename
in repository https://gitbox.apache.org/repos/asf/seatunnel.git

commit cd51d2b940eda99ddc18df0e4ded1c48873f4962
Author: Eric <gaojun2...@gmail.com>
AuthorDate: Wed Jan 24 10:32:25 2024 +0800

    Use default tablepath when can not get the tablepath from source config
---
 .../java/org/apache/seatunnel/api/table/catalog/CatalogTableUtil.java   | 2 +-
 .../src/main/java/org/apache/seatunnel/api/table/catalog/TablePath.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/CatalogTableUtil.java
 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/CatalogTableUtil.java
index 6b8d19ea71..6f2b6adeb2 100644
--- 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/CatalogTableUtil.java
+++ 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/CatalogTableUtil.java
@@ -215,7 +215,7 @@ public class CatalogTableUtil implements Serializable {
         } else {
             Optional<String> resultTableNameOptional =
                     
readonlyConfig.getOptional(CommonOptions.RESULT_TABLE_NAME);
-            tablePath = 
resultTableNameOptional.map(TablePath::of).orElse(TablePath.EMPTY);
+            tablePath = 
resultTableNameOptional.map(TablePath::of).orElse(TablePath.DEFAULT);
         }
 
         return CatalogTable.of(
diff --git 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TablePath.java
 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TablePath.java
index 60f4b691bd..1257262187 100644
--- 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TablePath.java
+++ 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TablePath.java
@@ -34,7 +34,7 @@ public final class TablePath implements Serializable {
     private final String schemaName;
     private final String tableName;
 
-    public static final TablePath EMPTY = TablePath.of(null, null, null);
+    public static final TablePath DEFAULT = TablePath.of("default", "default", 
"default");
 
     public static TablePath of(String fullName) {
         return of(fullName, false);

Reply via email to