Class TaskCorruptedException

All Implemented Interfaces:
Serializable

public class TaskCorruptedException
extends StreamsException
Indicates a specific task is corrupted and need to be re-initialized. It can be thrown when 1) Under EOS, if the checkpoint file does not contain offsets for corresponding store's changelogs, meaning previously it was not close cleanly; 2) Out-of-range exception thrown during restoration, meaning that the changelog has been modified and we re-bootstrap the store.
See Also:
Serialized Form
  • Constructor Details

    • TaskCorruptedException

      public TaskCorruptedException​(Set<TaskId> corruptedTasks)
    • TaskCorruptedException

      public TaskCorruptedException​(Set<TaskId> corruptedTasks, InvalidOffsetException e)
  • Method Details

    • corruptedTasks

      public Set<TaskId> corruptedTasks()