(hudi) branch master updated: [HUDI-7107] Reused MetricsReporter fails to publish metrics in Spark streaming job (#10132)

[danny0405]

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

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new eaba1146afc [HUDI-7107] Reused MetricsReporter fails to publish 
metrics in Spark streaming job (#10132)
eaba1146afc is described below

commit eaba1146afc83e5e70ef520704a76a15a75c9aad
Author: Akira Ajisaka <akir...@amazon.com>
AuthorDate: Tue Nov 21 11:37:47 2023 +0900

    [HUDI-7107] Reused MetricsReporter fails to publish metrics in Spark 
streaming job (#10132)
---
 .../src/main/java/org/apache/hudi/metrics/Metrics.java                  | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/Metrics.java
 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/Metrics.java
index f71d394238e..47ee23bcc2f 100644
--- 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/Metrics.java
+++ 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/Metrics.java
@@ -86,6 +86,8 @@ public class Metrics {
 
   public static synchronized void shutdownAllMetrics() {
     METRICS_INSTANCE_PER_BASEPATH.values().forEach(Metrics::shutdown);
+    // to avoid reusing already stopped metrics
+    METRICS_INSTANCE_PER_BASEPATH.clear();
   }
 
   private List<MetricsReporter> 
addAdditionalMetricsExporters(HoodieWriteConfig metricConfig) {