From 5de9966336010719d9b4c69024d78e9d83a45029 Mon Sep 17 00:00:00 2001 From: gnehil Date: Fri, 28 Jul 2023 17:45:44 +0800 Subject: [PATCH] do not exec create table when save mode is null --- .../org/apache/seatunnel/connectors/doris/sink/DorisSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSink.java b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSink.java index 708ddfd0d3c9..20f2d3986716 100644 --- a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSink.java +++ b/seatunnel-connectors-v2/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) { + if (catalogTable != null && userConfigSaveMode != null) { try (DorisCatalog dorisCatalog = new DorisCatalog( "Doris",