(iceberg) branch main updated: Core: Implement close() method in CompositeMetricsReporter (#13535)

[amoghj]

This is an automated email from the ASF dual-hosted git repository.

amoghj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new ae672a270d Core: Implement close() method in CompositeMetricsReporter 
(#13535)
ae672a270d is described below

commit ae672a270dceea92fc56fc2ca51a1a9d03715122
Author: Anoop Johnson <g...@anoopjohnson.com>
AuthorDate: Fri Jul 11 16:04:08 2025 -0700

    Core: Implement close() method in CompositeMetricsReporter (#13535)
---
 .../java/org/apache/iceberg/metrics/MetricsReporters.java     | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/core/src/main/java/org/apache/iceberg/metrics/MetricsReporters.java 
b/core/src/main/java/org/apache/iceberg/metrics/MetricsReporters.java
index 053823fe2a..9f54da3443 100644
--- a/core/src/main/java/org/apache/iceberg/metrics/MetricsReporters.java
+++ b/core/src/main/java/org/apache/iceberg/metrics/MetricsReporters.java
@@ -78,6 +78,17 @@ public class MetricsReporters {
       }
     }
 
+    @Override
+    public void close() {
+      for (MetricsReporter reporter : reporters) {
+        try {
+          reporter.close();
+        } catch (Exception e) {
+          LOG.warn("Failed to close metrics reporter {}", 
reporter.getClass().getName(), e);
+        }
+      }
+    }
+
     Set<MetricsReporter> reporters() {
       return Collections.unmodifiableSet(reporters);
     }