From 91306ad58618a8a9f0ef19475e9ee6b7b9362864 Mon Sep 17 00:00:00 2001 From: "jiafeng.zhang" Date: Sun, 9 Oct 2022 15:40:33 +0800 Subject: [PATCH] batchSizeRows batchSizeRows --- doriswriter/doc/doriswriter.md | 6 +++--- .../com/alibaba/datax/plugin/writer/doriswriter/Key.java | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/doriswriter/doc/doriswriter.md b/doriswriter/doc/doriswriter.md index 3bcbf9ff..53f1de34 100644 --- a/doriswriter/doc/doriswriter.md +++ b/doriswriter/doc/doriswriter.md @@ -140,15 +140,15 @@ DorisWriter 通过Doris原生支持Stream load方式导入数据， DorisWriter - 默认值：无 -* **maxBatchRows** +* **batchSizeRows** - - 描述：每批次导入数据的最大行数。和 **maxBatchByteSize** 共同控制每批次的导入数量。每批次数据达到两个阈值之一，即开始导入这一批次的数据。 + - 描述：每批次导入数据的最大行数。和 **batchByteSize** 共同控制每批次的导入数量。每批次数据达到两个阈值之一，即开始导入这一批次的数据。 - 必选：否 - 默认值：500000 * **batchByteSize** - - 描述：每批次导入数据的最大数据量。和 ** maxBatchRows** 共同控制每批次的导入数量。每批次数据达到两个阈值之一，即开始导入这一批次的数据。 + - 描述：每批次导入数据的最大数据量。和 **batchSizeRows** 共同控制每批次的导入数量。每批次数据达到两个阈值之一，即开始导入这一批次的数据。 - 必选：否 - 默认值：104857600 diff --git a/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Key.java b/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Key.java index 46f31499..4335936f 100644 --- a/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Key.java +++ b/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Key.java @@ -48,7 +48,7 @@ public class Key implements Serializable { public static final String LOAD_PROPS_LINE_DELIMITER = "line_delimiter"; public static final String LOAD_PROPS_COLUMN_SEPARATOR = "column_separator"; - public static final String MAX_BATCH_ROWS = "maxBatchRows"; + public static final String MAX_BATCH_ROWS = "batchSizeRows"; public static final String BATCH_BYTE_SIZE = "batchByteSize"; public static final String MAX_RETRIES = "maxRetries"; public static final String LABEL_PREFIX = "labelPrefix"; @@ -56,7 +56,7 @@ public class Key implements Serializable { public static final String CONNECT_TIMEOUT = "connectTimeout"; private final Configuration options; - private static final long DEFAULT_MAX_BATCH_ROWS = 50_0000; + private static final long DEFAULT_MAX_BATCH_ROWS = 500000; private static final long DEFAULT_BATCH_BYTE_SIZE = 90 * 1024 * 1024; private static final int DEFAULT_MAX_RETRIES = 0;