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

这个错误感觉是 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" 写道： >请教各位： >我用fli

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

补充下上个问题中图片的文字版： 图一： if (count > 300) { mutator.flush() count = 0 } count = count + 1 图二： Caused by: org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException: Failed 101 actions: Operation Timeout: 101 times, servers with issues: 172.xx.x.x,16020,16011736

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

请教各位： 我用flink实时写入hbase，继承RichSinkFunction后用的hbase的BufferedMutator，每当写入一定量的数据后，就用flush的方法，类似这样： 但是我的任务会频繁报出如下错误： 感觉貌似是我代码的问题导致的，但又不知道原因，希望得到指导，感激