john801205 opened a new pull request, #16970:
URL: https://github.com/apache/iceberg/pull/16970

   ### Summary 
   The rewrite data files procedure reported partial commit failures even when 
all commits succeeded, because it derived the total commit count as 
min(totalGroupCount, maxCommits). When groups are batched into groupsPerCommit 
= ceil(totalGroupCount / maxCommits) per commit, the actual number of commits 
is ceil(totalGroupCount / groupsPerCommit), which can be smaller. The mismatch 
made totalCommits - succeededCommits positive even with zero failures.
   
   Compute totalCommits as ceil(totalGroupCount / groupsPerCommit) so the 
failed commit count is correct. Also make succeededCommits an AtomicInteger 
since it is incremented from multiple rewrite threads.
   
   ### Issues
   * https://github.com/apache/iceberg/issues/16971
   
   ### Related PRs
   * https://github.com/apache/iceberg/pull/9611
   * https://github.com/apache/iceberg/pull/12120


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


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to