sydneyhoran commented on issue #8519:
URL: https://github.com/apache/hudi/issues/8519#issuecomment-1533514539

   The reason I was getting an error on deleting records without tombstone was 
because we were testing by starting from a midpoint of a Kafka topic, so I 
suspect Deltastreamer didn't know what to do with `"d"` messages for records 
that didn't exist. Had to add a few more logging lines and check executor logs 
to find out what was going on.
   
   We'll make sure jobs are starting fresh from the start of topics and turn on 
`commit-on-errors` if needed to get around non-existent deletes (until there is 
a possible fix for that).


-- 
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]

Reply via email to