jsun98 commented on issue #6508: fix KafkaSupervisor stats report error URL: https://github.com/apache/incubator-druid/pull/6508#issuecomment-432508275 @jihoonson thanks for the comment. In `getCurrentTotalStats()` in `KafkaSupervisor` the code ```java for (int groupId : pendingCompletionTaskGroups.keySet()) { TaskGroup group = taskGroups.get(groupId); ``` loops over the group IDs of pendingCompletionTaskGroups, but tries to get a group from taskGroup instead of pendingCompletionTaskGroups. This causes a `NullPointerException` since these 2 groups are supposed be disjoint.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org For additional commands, e-mail: commits-h...@druid.apache.org
