zdl11111 commented on issue #9940:
URL: https://github.com/apache/hudi/issues/9940#issuecomment-1789990183
> you need to set up the `precombine.field` correctly so that the even
stream can sort based on the event time, the processing time sequence does not
guarantee the sementics.
Thanks for your help, after setting up the `precombine.field`, the record
can be updated, but cannot be deleted, is it correct?
Here is the input:
Flink SQL> select * from source;
| op | id | ts | name |
description | weight |
| +I | 111 | 13000 | scooter |
Big 2-wheel scooter | 5.179999828338623 |
| -U | 111 | 13000 | scooter |
Big 2-wheel scooter | 5.179999828338623 |
| +U | 111 | 15000 | scooter |
Big 2-wheel scooter | 5.170000076293945 |
| -D | 111 | 17000 | scooter |
Big 2-wheel scooter | 5.170000076293945 |
Received a total of 4 rows
Then insert into a hudi table from this source, 'id' is the pk and 'ts' is
the precombine.field
Then query the data from the hudi table:
**The recore with id "111" is still alive:
| +I | 111 | 15000 | scooter |
Big 2-wheel scooter | 5.170000076293945 |**
Should it be the correct result? I will appreciate it if you could help me
with it!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@hudi.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
