You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by bradyMk <zh...@126.com> on 2020/11/27 09:43:57 UTC

flink实时写入Hbase丢数据问题

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



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