flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nielsbasjes <...@git.apache.org>
Subject [GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink
Date Sun, 07 Jan 2018 21:28:08 GMT
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.



---

Mime
View raw message