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 4229e256..bad4ed73 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 @@ -16,7 +16,7 @@ public class DorisWriterOptions implements Serializable { private static final long MEGA_BYTES_SCALE = KILO_BYTES_SCALE * KILO_BYTES_SCALE; private static final int MAX_RETRIES = 1; private static final int BATCH_ROWS = 500000; - private static final long BATCH_BYTES = 100 * MEGA_BYTES_SCALE; + private static final long BATCH_BYTES = 90 * MEGA_BYTES_SCALE; private static final String KEY_LOAD_PROPS_FORMAT = "format"; public enum StreamLoadFormat {