[ https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser updated FLINK-28910: ----------------------------------- Priority: Major (was: Blocker) > CDC From Mysql To Hbase Bugs > ---------------------------- > > Key: FLINK-28910 > URL: https://issues.apache.org/jira/browse/FLINK-28910 > Project: Flink > Issue Type: Bug > Components: Connectors / HBase > Reporter: TE > Priority: Major > Labels: pull-request-available, stale-blocker > > I use Flink for CDC from Mysql to Hbase. > The problem I encountered is that the Mysql record is updated (not deleted), > but the record in hbase is deleted sometimes. > I tried to analyze the problem and found the reason as follows: > The update action of Mysql will be decomposed into delete + insert by Flink. > The Hbase connector uses a mutator to handle this set of actions. > However, if the order of these actions is not actively set, the processing of > the mutator will not guarantee the order of execution. > Therefore, when the update of Mysql is triggered, it is possible that hbase > actually performed the actions in the order of put + delete, resulting in the > data being deleted. -- This message was sent by Atlassian Jira (v8.20.10#820010)