umustafi commented on code in PR #3823:
URL: https://github.com/apache/gobblin/pull/3823#discussion_r1388695256


##########
gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java:
##########
@@ -484,7 +484,9 @@ public synchronized void setActive(boolean active) {
           log.error("Exception encountered when shutting down DagManager 
threads.", e);
         }
       }
-    } catch (IOException e) {
+    } catch (Throwable e) {

Review Comment:
   We are not catching `NullPointerException` that occurred here 
https://github.com/apache/gobblin/blob/9e30c6c3bca857942fba5d10345b1be14adc1942/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java#L435
 we're only catching IOException which results in leader transition silently 
not completing if NPE or something occurs. It is printing the stack trace but 
we already set `this.active = true beforehand` so it remains as leader. 



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to