[GOBBLIN-2161] Read logExporter classname from config property (#4063)

linkedin · Oct 3, 2024 · a6a2f72 · a6a2f72
1 parent 6597980
commit a6a2f72
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...s-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetrics.java b/...s-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetrics.java
@@ -65,7 +65,8 @@ protected MetricExporter initializeMetricExporter(State state) {
     if (state.getPropAsBoolean(ConfigurationKeys.METRICS_REPORTING_OPENTELEMETRY_LOGEXPORTER_ENABLED,
         ConfigurationKeys.DEFAULT_METRICS_REPORTING_OPENTELEMETRY_LOGEXPORTER_ENABLED)) {
       try {
-        Class<?> clazz = Class.forName(ConfigurationKeys.METRICS_REPORTING_OPENTELEMETRY_LOGEXPORTER_CLASSNAME);
+        log.info("Initializing opentelemetry LogExporter class");
+        Class<?> clazz = Class.forName(state.getProp(ConfigurationKeys.METRICS_REPORTING_OPENTELEMETRY_LOGEXPORTER_CLASSNAME));
         Method instanceMethod = clazz.getMethod("instance");
         // Invoke the method to get the singleton instance
         return metricExporter = (MetricExporter) instanceMethod.invoke(null);