请教各位:
我用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/

回复