You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Bruce Wong (Jira)" <ji...@apache.org> on 2021/12/15 12:05:00 UTC

[jira] [Created] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

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)