pvary commented on issue #9773: URL: https://github.com/apache/iceberg/issues/9773#issuecomment-1965862091
What do you mean by > FlinkSink in append-mode Could you please share your sink definition? The code snippet highlighted by you is part of the `BaseEqualityDeltaWriter`, which means, that it will only write positional delete rows, if it is also writing out equality delete rows... Could you please confirm that you have all of the expected types of files in your table: - data files for new rows (value 1, value 2, value 3) - equality delete files for the deleted records (value 1, value 2) - positional delete files for the records inserted and deleted in the same checkpoint (value 2) If you have these files, the issue is most probably how you read the data. Could you please share that part of the code too? Thanks, Peter -- 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: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org
