Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2332 I agree with @delding here. > * Method that does a batch call on Deletes, Gets, Puts, Increments and Appends. * The ordering of execution of the actions is not defined. Meaning if you do a Put and a * Get in the same {@link #batch} call, you will not necessarily be * guaranteed that the Get returns what the Put had put. is the javadoc for batch API. Anyway here we don't do get operation but still the order of execution among mutations is not guarenteed. Regarding > storing input records in a state backend and flushing to HBase upon receiving a checkpoint barrier. Where is this being done in Flink. Just for understanding.
--- 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---