From 642fb404ec9848e44b96b1d0c9c8c677dbe92ba0 Mon Sep 17 00:00:00 2001 From: Tamas Nemeth Date: Tue, 16 Jul 2024 11:50:15 +0200 Subject: [PATCH] fix(ingest/spark): Fixing Micrometer warning (#10882) --- metadata-integration/java/spark-lineage-beta/README.md | 4 +++- .../src/main/java/datahub/spark/DatahubSparkListener.java | 8 +------- 2 files changed, 4 insertions(+), 8 deletions(-) diff --git a/metadata-integration/java/spark-lineage-beta/README.md b/metadata-integration/java/spark-lineage-beta/README.md index a643919664..b0753936dd 100644 --- a/metadata-integration/java/spark-lineage-beta/README.md +++ b/metadata-integration/java/spark-lineage-beta/README.md @@ -346,8 +346,10 @@ Use Java 8 to build the project. The project uses Gradle as the build tool. To b + ## Changelog +### Version 0.2.14 +- Fix warning about MeterFilter warning from Micrometer -### Version 0.2.12 +### Version 0.2.13 - Silencing some chatty warnings in RddPathUtils ### Version 0.2.12 diff --git a/metadata-integration/java/spark-lineage-beta/src/main/java/datahub/spark/DatahubSparkListener.java b/metadata-integration/java/spark-lineage-beta/src/main/java/datahub/spark/DatahubSparkListener.java index 54bb3821ed..96fa74d1bc 100644 --- a/metadata-integration/java/spark-lineage-beta/src/main/java/datahub/spark/DatahubSparkListener.java +++ b/metadata-integration/java/spark-lineage-beta/src/main/java/datahub/spark/DatahubSparkListener.java @@ -287,13 +287,7 @@ public class DatahubSparkListener extends SparkListener { } else { disabledFacets = ""; } - meterRegistry - .config() - .commonTags( - Tags.of( - Tag.of("openlineage.spark.integration.version", Versions.getVersion()), - Tag.of("openlineage.spark.version", sparkVersion), - Tag.of("openlineage.spark.disabled.facets", disabledFacets))); + ((CompositeMeterRegistry) meterRegistry) .getRegistries() .forEach(