flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhueske <...@git.apache.org>
Subject [GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink
Date Fri, 23 Sep 2016 10:56:16 GMT
Github user fhueske commented on the issue:

    https://github.com/apache/flink/pull/2332
  
    Thanks for looking into the Cassandra connector. Maybe @zentol (who implemented the Cassandra
connector) can comment how an HBase sink can be made fault-tolerant and what code could be
reused for that.
    
    Idempotent (put, delete) and non-idempotent modifications (increment, append) have different
implications on fault-tolerance semantics. I think it would be a good idea to separate both
types of modifications to make this difference more clear.
    
    I would be OK updating the version update to HBase 1.1.6 or 1.2.x under the condition
that these versions are backwards compatible to 1.1.2. @nielsbasjes, would that be OK for
you as well? We have an ongoing discussion to merge batch and streaming connectors. So this
code would end up in the same module as the batch `TableInputFormat` and we should keep the
HBase versions synced.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message