Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
We encounter a NullPointerException when initializing the DagActionStoreMonitor after moving the loading of DagActions on startup from the DagManager to the DagActionStoreMonitor. Metrics for the DagActionStoreMonitor were initialized by its parent class the HighLevelConsumer only before starting to consume Kafka messages, however with the refactor these metrics are needed beforehand. In this PR I separate the creation of these metrics into a separate function and call it before loading dagActions.