[Improve][API] Check catalog table names legal before send to downstream

apache · Aug 10, 2024 · 87e3be8 · 87e3be8
1 parent 3ad2d02
commit 87e3be8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...nel-api/src/main/java/org/apache/seatunnel/api/table/factory/TableSinkFactoryContext.java b/...nel-api/src/main/java/org/apache/seatunnel/api/table/factory/TableSinkFactoryContext.java
@@ -36,7 +36,9 @@ public class TableSinkFactoryContext extends TableFactoryContext {
     public TableSinkFactoryContext(
             CatalogTable catalogTable, ReadonlyConfig options, ClassLoader classLoader) {
         super(options, classLoader);
-        checkCatalogTableIllegal(Collections.singletonList(catalogTable));
+        if (catalogTable != null) {
+            checkCatalogTableIllegal(Collections.singletonList(catalogTable));
+        }
         this.catalogTable = catalogTable;
     }