Bruce Wong created FLINK-25330:
----------------------------------
Summary: Flink SQL doesn't retract all versions of Hbase data
Key: FLINK-25330
URL: https://issues.apache.org/jira/browse/FLINK-25330
Project: Flink
Issue Type: Bug
Components: Connectors / HBase
Affects Versions: 1.14.0
Reporter: Bruce Wong
Attachments: image-2021-12-15-20-00-22-767.png
h2. Background
When we use CDC to synchronize mysql data to HBase, we find that HBase deletes
only the last version of the specified rowkey when deleting mysql data. The
data of the old version still exists. You end up using the wrong data. And I
think its a bug of HBase connector.
The following figure shows Hbase data changes before and after mysql data is
deleted.
!image-2021-12-15-19-59-31-837.png|width=925,height=680!
h2.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
