补充下上个问题中图片的文字版: 图一: 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,1601173606933 at org.apache.hadoop.hbase.client.AsyncProcess$BatchErrors.makeException(AsyncProcess.java:297) at org.apache.hadoop.hbase.client.AsyncProcess$BatchErrors.access$2300(AsyncProcess.java:273) at org.apache.hadoop.hbase.client.AsyncProcess.waitForAllPreviousOpsAndReset(AsyncProcess.java:1906) at org.apache.hadoop.hbase.client.BufferedMutatorImpl.backgroundFlushCommits(BufferedMutatorImpl.java:250) at org.apache.hadoop.hbase.client.BufferedMutatorImpl.flush(BufferedMutatorImpl.java:213) at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56) at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:637) ----- Best Wishes -- Sent from: http://apache-flink.147419.n8.nabble.com/