update table identified to table path

apache · Jan 7, 2025 · 428e2f6 · 428e2f6
1 parent adb656e
commit 428e2f6
Showing 1 changed file with 3 additions and 0 deletions.
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
@@ -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));
     }