flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yang Peng <yangpengklf...@gmail.com>
Subject Re: 写HBase慢造成消息堆积,有没有异步IO可以用于sink或者outputFormat的方法?
Date Mon, 08 Apr 2019 07:57:31 GMT
有没有参考flink官方源码示例中的这个例子:
org.apache.flink.addons.hbase.example.HBaseWriteExample
这个类写的就是flink插入HBase 效率很高 我们实际生产也用到了插入HBase但是效率很高,你可以看一下这个源码;

张作峰 <mail@zhangzuofeng.cn> 于2019年4月6日周六 下午4:38写道:

> 业务场景中,需要将处理后的消息写入到HBase中,由于写入HBase慢,引起消息堆积。
> 通过Stream API 有没有方法可以异步批量发送?
> 谢谢!
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message