[GOBBLIN-2038] Fix bug where monitor startup is never occurring (apac…

…he#3917)
arjun4084346 · Apr 8, 2024 · a25c839 · a25c839
1 parent 698b351
commit a25c839
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 16 deletions.
diff --git a/...vice/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java b/...vice/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java
@@ -165,18 +165,16 @@ public synchronized void setActive() {
       return;
     }
 
-    if (isActive) {
-      this.isActive = true;
-      initializeMonitor();
-      // Method that starts threads that processes queues
-      processQueues();
-      // Main thread that constantly polls messages from kafka
-      consumerExecutor.execute(() -> {
-        while (!shutdownRequested) {
-          consume();
-        }
-      });
-    }
+    this.isActive = true;
+    initializeMonitor();
+    // Method that starts threads that processes queues
+    processQueues();
+    // Main thread that constantly polls messages from kafka
+    consumerExecutor.execute(() -> {
+      while (!shutdownRequested) {
+        consume();
+      }
+    });
   }
 
   @Override

diff --git a/...n-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java b/...n-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java
@@ -114,10 +114,8 @@ public synchronized void setActive() {
       return;
     }
 
-    if (isActive) {
-      this.isActive = true;
-      super.startUp();
-    }
+    this.isActive = true;
+    super.startUp();
   }
 
   @Override