Github user nielsbasjes commented on the issue:
https://github.com/apache/flink/pull/2332
FYI:
In close relation to this issue I submitted an enhancement at the HBase
side to support these kinds of usecases much better:
https://issues.apache.org/jira/browse/HBASE-19486
https://issues.apache.org/jira/browse/HBASE-19673
Simply put: You can now specify a max time the records may be kept in the
BufferedMutator. If they exceed this value then a flush will be done
automatically.---
