[HUDI-7107] Reused MetricsReporter fails to publish metrics in Spark …

…streaming job (apache#10132)
jonvex · Nov 21, 2023 · eaba114 · eaba114
1 parent 578e756
commit eaba114
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -86,6 +86,8 @@ public static synchronized Metrics getInstance(HoodieWriteConfig metricConfig) {
 
   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) {