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 Detail

      • TaskCorruptedException

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

      • corruptedTasks

        public Set<TaskId> corruptedTasks()