mirror of https://github.com/apache/druid.git
fix incorrect precondition check in `SupervisorManager.suspendOrResumeSupervisor` (#6364)
This check is reverse from the intention
This commit is contained in:
parent
f12ffd19a8
commit
399a5659b2
|
@ -95,7 +95,7 @@ public class SupervisorManager
|
||||||
{
|
{
|
||||||
Preconditions.checkState(started, "SupervisorManager not started");
|
Preconditions.checkState(started, "SupervisorManager not started");
|
||||||
Pair<Supervisor, SupervisorSpec> pair = supervisors.get(id);
|
Pair<Supervisor, SupervisorSpec> pair = supervisors.get(id);
|
||||||
Preconditions.checkNotNull(pair.lhs, "spec");
|
Preconditions.checkNotNull(pair.rhs, "spec");
|
||||||
synchronized (lock) {
|
synchronized (lock) {
|
||||||
Preconditions.checkState(started, "SupervisorManager not started");
|
Preconditions.checkState(started, "SupervisorManager not started");
|
||||||
SupervisorSpec nextState = suspend ? pair.rhs.createSuspendedSpec() : pair.rhs.createRunningSpec();
|
SupervisorSpec nextState = suspend ? pair.rhs.createSuspendedSpec() : pair.rhs.createRunningSpec();
|
||||||
|
|
Loading…
Reference in New Issue