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

["Bruce Wong (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471650#comment-17471650 ] 

Bruce Wong edited comment on FLINK-25330 at 1/10/22, 3:19 AM:
--------------------------------------------------------------

Hi [~jingge] ,

I created a new task to solve this problem. Please take a look at that. FLINK-25560

Thanks.


was (Author: bruce wong):
Hi [~jingge] ,

I created a new task to solve this problem. Please take a look at that. [FLINK-25560|https://issues.apache.org/jira/browse/FLINK-25560]

> 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
>            Reporter: Bruce Wong
>            Assignee: Jing Ge
>            Priority: Major
>              Labels: pull-request-available
>         Attachments: Flink-SQL-Test.zip, bundle_data.zip, bundle_data1.zip, image-2021-12-15-20-05-18-236.png, test_res.png, test_res2.png, test_res_1.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-20-05-18-236.png|width=910,height=669!
>  
> h2.  



--
This message was sent by Atlassian Jira
(v8.20.1#820001)