[GOBBLIN-1768] Fix constructor in KafkaJobStatusMonitorFactory so tha…

…t it can be injected (#3628)
apache · Jan 23, 2023 · 3dd0657 · 3dd0657
1 parent a1be38b
commit 3dd0657
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ice/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java b/...ice/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java
@@ -30,6 +30,7 @@
 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);