From 0554bd1bea980c1b19bb19a1a32074027eff5f3b Mon Sep 17 00:00:00 2001 From: hffariel Date: Mon, 14 Feb 2022 19:23:20 +0800 Subject: [PATCH] change the linking charactor of stream load label --- .../starrockswriter/manager/StarRocksWriterManager.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java b/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java index c28c8647..40acbd74 100644 --- a/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java +++ b/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java @@ -24,7 +24,7 @@ public class StarRocksWriterManager { private final StarRocksStreamLoadVisitor starrocksStreamLoadVisitor; private final StarRocksWriterOptions writerOptions; - private static final String UNDERSCORE = "_"; + private static final String DOT = "."; private final List buffer = new ArrayList<>(); private int batchCount = 0; @@ -123,12 +123,12 @@ public class StarRocksWriterManager { public String createBatchLabel() { StringBuilder sb = new StringBuilder(); if (!Strings.isNullOrEmpty(writerOptions.getLabelPrefix())) { - sb.append(writerOptions.getLabelPrefix()).append(UNDERSCORE); + sb.append(writerOptions.getLabelPrefix()).append(DOT); } return sb.append(writerOptions.getDatabase()) - .append(UNDERSCORE) + .append(DOT) .append(writerOptions.getTable()) - .append(UNDERSCORE) + .append(DOT) .append(UUID.randomUUID().toString()) .toString(); }