dramaticlly commented on code in PR #15003:
URL: https://github.com/apache/iceberg/pull/15003#discussion_r2737827969
##########
core/src/main/java/org/apache/iceberg/ManifestFilterManager.java:
##########
@@ -87,6 +87,8 @@ public String partition() {
// cache filtered manifests to avoid extra work when commits fail.
private final Map<ManifestFile, ManifestFile> filteredManifests =
Maps.newConcurrentMap();
+ // count of manifests that were rewritten with different manifest entry
status during filtering
Review Comment:
That's a good catch, moved to atomic integer in both ManifestFilterManager
and ManifestMergeManager
--
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]
