asija-varun92 opened a new issue, #13973: URL: https://github.com/apache/hudi/issues/13973
### Bug Description **What happened:** I am experiencing an issue where delete operations in a Hudi table do not propagate to another table when using DeltaStreamer. **What you expected:** I have one main hudi table in which I am setting '_hoodie_is_deleted' while upsert for deletion purpose. This is actually deleting the row from here. I have another pipeline which is a deltaStreamer job and that syncs the changes in this table to another hudi table. The mode of write in both is COW. Inserts and updates are working fine but deletion is not propagating to downstream table. **Steps to reproduce:** 1. Create hudi table using [options](https://github.com/asija-varun92/cdc-hudi-lakehouse/tree/main/src/hudi_config) 2. Run deltaStreamer job to propagate same changes into another hudi table. [my job](https://github.com/asija-varun92/hudi-data-sync) 3. Try inserting new row into 1st hudi table and run deltaS treamer job. it will work fine. Then try deleting the same row. It will be deleted from first table bit after running deltaStreamer job the delete operation will not propagate on the downstream table ### Environment **Hudi version:** **Query engine:** (Spark/Flink/Trino etc) **Relevant configs:** ### Logs and Stack Trace _No response_ -- 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]
