flink实时写入Hbase丢数据问题

[bradyMk]

大家好，最近有项目要把数据写入hbase，本人采用的是hbase api
中的BufferedMutator.flush的方法，每500条数据flush一下，但是发现这种方法偶尔会有十几行写入失败，这种情况下，这几十行数据就会丢失，请问大家有什么建议么？
该用什么方法实时写入hbase，怎么保证数据不会有丢失的情况呢？谢谢大家~



-----
Best Wishes
--
Sent from: http://apache-flink.147419.n8.nabble.com/