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