这个错误感觉是 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
补充下上个问题中图片的文字版:
图一:
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