[GitHub] jihoonson opened a new issue #5992: NPE while handling CheckpointNotice in KafkaSupervisor

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@druid.apache.org
For additional commands, e-mail: dev-help@druid.apache.org