You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 潘明文 <pa...@163.com> on 2022/03/22 01:59:47 UTC

hbase 写性能

HI,

    目前环境是hbase4个Region server节点，内存为128`256, 目前写入hbase7000——10000多每秒,这正常，是否有调优的空间。谢谢！


代码如下:
BufferedMutatorParams params= new BufferedMutatorParams(TableName.valueOf(key));
//设置缓存10m，当达到10m时数据会自动刷到hbase
params.writeBufferSize(10*1024*1024L);//设置缓存的大小
params.setWriteBufferPeriodicFlushTimeoutMs(5*1000L);//写缓存刷写时间为5s
BufferedMutator mutator = connection.getBufferedMutator(params);
mutator.mutate(recordList);
mutator.flush();
mutator.close();