do not exec create table when save mode is not equals to KEEP_SCHEMA_…

…AND_DATA
gnehil · Aug 15, 2023 · 34acbbe · 34acbbe
1 parent 5de9966
commit 34acbbe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSink.java b/...2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSink.java
@@ -176,7 +176,7 @@ public DataSaveMode getUserConfigSaveMode() {
 
     @Override
     public void handleSaveMode(DataSaveMode userConfigSaveMode) {
-        if (catalogTable != null && userConfigSaveMode != null) {
+        if (catalogTable != null && DataSaveMode.KEEP_SCHEMA_AND_DATA.equals(userConfigSaveMode)) {
             try (DorisCatalog dorisCatalog =
                     new DorisCatalog(
                             "Doris",