[fix][starrocks] update

apache · Mar 29, 2024 · a1975bb · a1975bb
1 parent c6c8b07
commit a1975bb
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...n/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkFactory.java b/...n/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkFactory.java
@@ -89,10 +89,10 @@ public TableSink createSink(TableSinkFactoryContext context) {
         String sinkDatabaseName = sinkConfig.getDatabase();
         String sinkTableName = sinkConfig.getTable();
         // to replace
-        if (StringUtils.isNotBlank(sourceDatabaseName)) {
-            sinkDatabaseName =
-                    sinkDatabaseName.replace(REPLACE_DATABASE_NAME_KEY, sourceDatabaseName);
-        }
+        sinkDatabaseName =
+                sinkDatabaseName.replace(
+                        REPLACE_DATABASE_NAME_KEY,
+                        sourceDatabaseName != null ? sourceDatabaseName : "");
         String finalTableName = this.replaceFullTableName(sinkTableName, tableId);
         // rebuild TableIdentifier and catalogTable
         TableIdentifier newTableId =