sunnyzhuzhu opened a new issue, #9299: URL: https://github.com/apache/iceberg/issues/9299
position delete in BaseEqualityDeltaWriter write function will lead to unstable result when equalityFieldColumns is not null and upsert is false. when equalityFieldColumns is not null and upsert is false, it will not call delete method in BaseEqualityDeltaWriter, but will do postion delete in write method, in this situation, as position delete will only delete equailty key in memory, so if flink checkpoint interval in two job with same source data is not the same, there will be different results in these two job. I think position delete is not need in write method, just call delete or deleteKey method in BaseEqualityDeltaWriter is enough. -- 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.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
