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

Posted to issues@flink.apache.org by nielsbasjes <gi...@git.apache.org> on 2018/01/07 21:28:08 UTC

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

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.



---