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

Liebing Yu edited comment on FLINK-26792 at 3/28/22, 12:15 PM:
---------------------------------------------------------------

[~ting.lt], can you give a small example that reproduces the problem? This way 
I can help you locate and fix the problem faster.


was (Author: liebing):
Can you give a small example that reproduces the problem? This way I can help 
you locate and fix the problem faster.

> BufferedMutator failed when insert and update with a flush in Hbase Sink
> ------------------------------------------------------------------------
>
>                 Key: FLINK-26792
>                 URL: https://issues.apache.org/jira/browse/FLINK-26792
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / HBase
>            Reporter: lothar
>            Priority: Major
>         Attachments: image-2022-03-22-14-03-18-558.png
>
>
> When I write data from Kafka to Hbase(CDC data contains Insert、Update), once 
> the first insert data and update data with same rowkey in a flush, the data 
> will be invalid.



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

Reply via email to