From 75f2ebc0956e9426ce628a86062273969536a946 Mon Sep 17 00:00:00 2001 From: hantmac Date: Wed, 2 Aug 2023 16:57:00 +0800 Subject: [PATCH] fix --- .../plugin/writer/databendwriter/util/DatabendWriterUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/databendwriter/src/main/java/com/alibaba/datax/plugin/writer/databendwriter/util/DatabendWriterUtil.java b/databendwriter/src/main/java/com/alibaba/datax/plugin/writer/databendwriter/util/DatabendWriterUtil.java index 00a7c62a..036baf69 100644 --- a/databendwriter/src/main/java/com/alibaba/datax/plugin/writer/databendwriter/util/DatabendWriterUtil.java +++ b/databendwriter/src/main/java/com/alibaba/datax/plugin/writer/databendwriter/util/DatabendWriterUtil.java @@ -32,7 +32,7 @@ public final class DatabendWriterUtil { LOG.error("Replace mode must has onConflictColumn conf"); return; } - // for databend if you want to use replace mode, the writeMode should be: "writeMode": "replace (userid)" + // for databend if you want to use replace mode, the writeMode should be: "writeMode": "replace" writeDataSqlTemplate.append("REPLACE INTO %s (") .append(StringUtils.join(columns, ",")).append(") ").append(onConFlictDoString(onConflictColumns)) .append(" VALUES");