[gobblin] branch master updated: [GOBBLIN-1768] Fix constructor in KafkaJobStatusMonitorFactory so that it can be injected (#3628)

[wl...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 3dd0657e9 [GOBBLIN-1768] Fix constructor in KafkaJobStatusMonitorFactory so that it can be injected (#3628)
3dd0657e9 is described below

commit 3dd0657e9ac87ce34fdaa196145d441eeba5e340
Author: William Lo <lo...@gmail.com>
AuthorDate: Mon Jan 23 11:03:27 2023 -0800

    [GOBBLIN-1768] Fix constructor in KafkaJobStatusMonitorFactory so that it can be injected (#3628)
---
 .../gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java
index d4129f1ea..0b80b4f2e 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java
@@ -30,6 +30,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.gobblin.configuration.ConfigurationKeys;
 import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryConfigurationKeys;
 import org.apache.gobblin.metrics.kafka.KafkaAvroSchemaRegistry;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
 import org.apache.gobblin.runtime.troubleshooter.JobIssueEventHandler;
 import org.apache.gobblin.runtime.troubleshooter.MultiContextIssueRepository;
 import org.apache.gobblin.util.ConfigUtils;
@@ -50,6 +51,11 @@ public class KafkaJobStatusMonitorFactory implements Provider<KafkaJobStatusMoni
   private final boolean instrumentationEnabled;
 
   @Inject
+  public KafkaJobStatusMonitorFactory(Config config, JobIssueEventHandler jobIssueEventHandler, MultiContextIssueRepository issueRepository,
+      GobblinInstanceEnvironment env) {
+    this(config, jobIssueEventHandler, issueRepository, env.isInstrumentationEnabled());
+  }
+
   public KafkaJobStatusMonitorFactory(Config config, JobIssueEventHandler jobIssueEventHandler, MultiContextIssueRepository issueRepository,
       boolean instrumentationEnabled) {
     this.config = Objects.requireNonNull(config);