jihoonson opened a new issue #5992: NPE while handling CheckpointNotice in KafkaSupervisor URL: https://github.com/apache/incubator-druid/issues/5992 The error occurs at the below check in the `CheckpointNotice` class. ```java Preconditions.checkNotNull( sequenceTaskGroup.get(sequenceName), "WTH?! cannot find task group for this sequence [%s], sequencesTaskGroup map [%s], taskGroups [%s]", sequenceName, sequenceTaskGroup, taskGroups ); ``` This happens in the below scenario. 1) One of tasks in a taskGroup has succeeded, and the supervisor stopped all tasks in that group. 2) One of tasks sent a checkpoint request to the supervisor before stopping. 3) The supervisor received the checkpoint request after tidying up all information of the taskGroup.
---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
