diff --git a/chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java b/chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java index 615394d2df..a2a7e25a1e 100644 --- a/chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java +++ b/chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java @@ -50,7 +50,7 @@ public StarRocksSinkFactory(SyncConf syncConf) { JsonUtil.toObject( JsonUtil.toJson(syncConf.getWriter().getParameter()), StarRocksConf.class); - int batchSize = syncConf.getWriter().getIntVal("batchSize", 10240); + int batchSize = syncConf.getWriter().getIntVal("batchSize", 1024); starRocksConf.setBatchSize(batchSize); super.initCommonConf(starRocksConf); } diff --git "a/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/hbase/hbase-sink.md" "b/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/hbase/hbase-sink.md" index 18eb33e4f5..c702364750 100644 --- "a/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/hbase/hbase-sink.md" +++ "b/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/hbase/hbase-sink.md" @@ -27,6 +27,17 @@ hbase1.4 - 默认值:无 +- **column** + + - 描述:要写入的hbase字段。 + - name:指定写入的hbase列,必须为 列族:列名 的格式; + - type:指定源数据的类型,format指定日期类型的格式 + - 必选:是 + - 字段类型:List + - 默认值:无 + - 注意:为了支持数据中某一列当做row_key这种情况,设置字符串rowkey为关键字,如果某一列name为rowkey,那么该列将不会写入 + + - **encoding** - 描述:编码 - 必选:否 @@ -58,6 +69,13 @@ hbase1.4
+- **batchSize** + + - 描述:一次性批量提交的记录数大小,该值可以极大减少ChunJun与数据库的网络交互次数,并提升整体吞吐量。但是该值设置过大可能会造成ChunJun运行进程OOM情况 + - 必选:否 + - 参数类型:int + - 默认值:1 + - **rowkeyExpress** - 描述: 用于构造rowkey的描述信息,采用字符串格式,形式如下