Tan-JiaLiang opened a new pull request, #30: URL: https://github.com/apache/flink-connector-hbase/pull/30
## What is the purpose of the change Current we put the `Mutation` into `BufferedMutator` directly, when `Mutation` have a `Delete` followed by `Put` to same column family or columns or rows, only the `Delete` is happening while the `Put` is ignored so atomicity of `Mutation` is broken for such cases. See https://issues.apache.org/jira/browse/HBASE-8626. ## Brief change log - *add `mutationBuffer` to resolve the mutation write conflicts problem* ## Verifying this change This change is already covered by existing tests, such as - *org.apache.flink.connector.hbase1.HBaseConnectorITCase#testTableSinkWithChangelog* - *org.apache.flink.connector.hbase2.HBaseConnectorITCase#testTableSinkWithChangelog* -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
