YARN-3604. Fixed ZKRMStateStore#removeApplication to also disable watch. Contributed Zhihai Xu
(cherry picked from commit d0b73287c2
)
This commit is contained in:
parent
8d07116266
commit
5a1c2fed34
|
@ -323,6 +323,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
|
|
||||||
YARN-3600. AM container link is broken (Naganarasimha G R via tgraves)
|
YARN-3600. AM container link is broken (Naganarasimha G R via tgraves)
|
||||||
|
|
||||||
|
YARN-3604. Fixed ZKRMStateStore#removeApplication to also disable watch.
|
||||||
|
(zhihai xu via jianhe)
|
||||||
|
|
||||||
Release 2.7.1 - UNRELEASED
|
Release 2.7.1 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -827,8 +827,8 @@ public class ZKRMStateStore extends RMStateStore {
|
||||||
public synchronized void removeApplication(ApplicationId removeAppId)
|
public synchronized void removeApplication(ApplicationId removeAppId)
|
||||||
throws Exception {
|
throws Exception {
|
||||||
String appIdRemovePath = getNodePath(rmAppRoot, removeAppId.toString());
|
String appIdRemovePath = getNodePath(rmAppRoot, removeAppId.toString());
|
||||||
if (existsWithRetries(appIdRemovePath, true) != null) {
|
if (existsWithRetries(appIdRemovePath, false) != null) {
|
||||||
deleteWithRetries(appIdRemovePath, true);
|
deleteWithRetries(appIdRemovePath, false);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue