Github user delding commented on the issue:
    Hi @fhueske , in HBase writes to a single row have ACID guarantee. The 
exactly once semantic can be implemented the way CassandraSink did, storing 
input records in a state backend and flushing to HBase upon receiving a 
checkpoint barrier. One thing that might be a concern is the order of execution 
of these writes are not defined when making such a batch call. In other words, 
a write of an earlier record could be observed later, but this could be also 
true even sending each write immediately. So what do you think if implement 
fault tolerance the same way as Cassandra Sink? 

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 or file a JIRA ticket
with INFRA.

Reply via email to