From 428e2f655f794228c44d4e703cf3e22ea9d8961c Mon Sep 17 00:00:00 2001 From: Cheun99 <1076178950@qq.com> Date: Mon, 6 Jan 2025 10:36:52 +0800 Subject: [PATCH] update table identified to table path --- .../java/org/apache/seatunnel/api/table/catalog/TablePath.java | 3 +++ 1 file changed, 3 insertions(+) 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 30edc7ac80e..858090d0b69 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 @@ -65,6 +65,9 @@ public static TablePath of(String fullName, boolean schemaFirst) { if (paths.length == 3) { return of(paths[0], paths[1], paths[2]); } + if (paths.length > 3) { + return of(null, fullName); + } throw new IllegalArgumentException( String.format("Cannot get split '%s' to get databaseName and tableName", fullName)); }