Class ErrorPartitionResetTask

  • All Implemented Interfaces:, java.lang.AutoCloseable, java.lang.Runnable

    public class ErrorPartitionResetTask
    extends java.lang.Object
    implements java.lang.Runnable,
    A task that iterates over store version resources and reset error partitions if they meet the following criteria:
    1. The store version resource is the current version.
    2. The error partition only has exactly one error replica.
    3. For L/F model, using EV to check error replicas misses internal error replica states. For example, a replica is shown Leader in EV but actually ERROR in offline push status.
    • Constructor Detail

    • Method Detail

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
      • close

        public void close()
        Cause ErrorPartitionResetTask to stop executing.
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface