OSDir


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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


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@xxxxxxxxxxxxxxxx


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@xxxxxxxxxxxxxxxx
For additional commands, e-mail: dev-help@xxxxxxxxxxxxxxxx