Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
case CONNECTION_SUSPENDED: LOG.warn("ZooKeeper connection SUSPENDED. Changes to the submitted job " + "graphs are not monitored (temporarily)."); case CONNECTION_LOST: LOG.warn("ZooKeeper connection LOST. Changes to the submitted job " + "graphs are not monitored (permanently)."); break; case CONNECTION_RECONNECTED: LOG.info("ZooKeeper connection RECONNECTED. Changes to the submitted job " + "graphs are monitored again."); case INITIALIZED: LOG.info("SubmittedJobGraphsPathCacheListener initialized"); break;
For CONNECTION_SUSPENDED and CONNECTION_RECONNECTED, the break statement is missing.
This would result in unrelated event logging.