From 293286ea142da8904988ef64c888e1f2cccea719 Mon Sep 17 00:00:00 2001 From: fariel Date: Fri, 13 Aug 2021 10:29:03 +0800 Subject: [PATCH] remove ` from columns --- .../datax/plugin/writer/doriswriter/DorisWriterOptions.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriterOptions.java b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriterOptions.java index 9add926d..1b3f525f 100644 --- a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriterOptions.java +++ b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriterOptions.java @@ -8,6 +8,7 @@ import com.alibaba.datax.plugin.rdbms.util.DBUtilErrorCode; import java.util.List; import java.util.Map; +import java.util.stream.Collectors; public class DorisWriterOptions implements Serializable { @@ -73,7 +74,7 @@ public class DorisWriterOptions implements Serializable { } public List getColumns() { - return options.getList(KEY_COLUMN, String.class); + return options.getList(KEY_COLUMN, String.class).stream().map(str -> str.replace("`", "")).collect(Collectors.toList()); } public List getPreSqlList() {