public static interface Executor.ExecutionTaskWaiter
Modifier and Type | Method and Description |
---|---|
List<ExecutionTask> |
waitForAnyTaskToFinish(AbstractExecutorReplicaMovement movement)
This method periodically checks Kafka to see if any partition reassignment has finished or not.
|
List<ExecutionTask> waitForAnyTaskToFinish(AbstractExecutorReplicaMovement movement)
movement
- the replica movement whose execution tasks this method will wait for.
It can call AbstractExecutorReplicaMovement.maybeReexecuteTasks()
to re-execute tasks while waiting.ExecutionTask
s that have finished