zdl11111 commented on issue #9940: URL: https://github.com/apache/hudi/issues/9940#issuecomment-1786397985
> I think it is because the sink materializer, you need to remove it first. Thanks for your reply! Now I can delete the data correctly, because I changed the datasource, before was | op | id | ts | name | description | weight | | -U | 111 | 13000 | scooter | Big 2-wheel scooter | 5.179999828338623 | | +U | 111 | 15000 | scooter | Big 2-wheel scooter | 5.170000076293945 | **| -D | 111 | 16000 | scooter | Big 2-wheel scooter | 5.170000076293945 |** After changing it to | op | id | ts | name | description | weight | | -U | 111 | 13000 | scooter | Big 2-wheel scooter | 5.179999828338623 | | +U | 111 | 15000 | scooter | Big 2-wheel scooter | 5.170000076293945 | **| -D | 111 | 15000 | scooter | Big 2-wheel scooter | 5.170000076293945 |** the record with id(**primary key**) "111" is deleted successfully, now I am wondering if I want to delete a record correctly, do I need to set each col to corresponding to data in the current table, or I just need to set the primary key to be the same, when using debezium format data as source. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
