Re:关于flink实时写入hbase用flush方法频繁报操作超时问题

Mon, 23 Nov 2020 21:17:36 -0800 


这个错误感觉是 Hbase 的错误。具体实现的话，你可以参考社区的 HBaseSinkFunction[1] 的实现。
[1] 
https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java
Best,
Hailong




在 2020-11-24 09:32:55，"bradyMk" <[email protected]> 写道：
>请教各位：
>我用flink实时写入hbase，继承RichSinkFunction后用的hbase的BufferedMutator，每当写入一定量的数据后，就用flush的方法，类似这样：
><http://apache-flink.147419.n8.nabble.com/file/t802/%E6%8D%95%E8%8E%B71.png> 
>但是我的任务会频繁报出如下错误：
><http://apache-flink.147419.n8.nabble.com/file/t802/%E6%8D%95%E8%8E%B7.png> 
>感觉貌似是我代码的问题导致的，但又不知道原因，希望得到指导，感激不尽~
>
>
>
>-----
>Best Wishes
>--
>Sent from: http://apache-flink.147419.n8.nabble.com/






















					回复