diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java index 700408e6633..fcc16fdb71a 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java @@ -636,6 +636,7 @@ public ComponentInstanceState transition(ComponentInstance instance, cancelStatus.getTargetVersion())) { // previous upgrade didn't happen so just go back to READY LOG.info("{} nothing to cancel", event.getContainerId()); + instance.upgradeInProgress.set(false); cancelStatus.decContainersThatNeedUpgrade(); instance.setContainerState(ContainerState.READY); ComponentEvent checkState = new ComponentEvent(