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);