Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
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 [email protected] or file a JIRA ticket
with INFRA.
---
