Class CheckTopologyTask


  • public class CheckTopologyTask
    extends Object
    The check topology task checks for changes in the topology and queue configuration and reassigns jobs. If the leader instance finds a dead instance it reassigns its jobs to live instances. The leader instance also checks for unassigned jobs and tries to assign them. If an instance detects jobs which it doesn't process anymore it reassigns them as well.
    • Constructor Detail

      • CheckTopologyTask

        public CheckTopologyTask​(JobManagerConfiguration config)
        Constructor
        Parameters:
        config - The configuration
    • Method Detail

      • assignUnassignedJobs

        public void assignUnassignedJobs()
        Try to assign unassigned jobs as there might be changes in: - queue configurations - topology - capabilities
      • fullRun

        public void fullRun()
        One maintenance run