YARN-985. Nodemanager should log where a resource was localized (Ravi Prakash via jeagles)
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1511100 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
cb7c15cd37
commit
3e0203a3a4
@ -1158,6 +1158,9 @@ Release 0.23.10 - UNRELEASED
|
|||||||
|
|
||||||
IMPROVEMENTS
|
IMPROVEMENTS
|
||||||
|
|
||||||
|
YARN-985. Nodemanager should log where a resource was localized (Ravi
|
||||||
|
Prakash via jeagles)
|
||||||
|
|
||||||
OPTIMIZATIONS
|
OPTIMIZATIONS
|
||||||
|
|
||||||
BUG FIXES
|
BUG FIXES
|
||||||
|
@ -242,6 +242,7 @@ public boolean remove(LocalizedResource rem, DeletionService delService) {
|
|||||||
delService.delete(getUser(), getPathToDelete(rsrc.getLocalPath()));
|
delService.delete(getUser(), getPathToDelete(rsrc.getLocalPath()));
|
||||||
}
|
}
|
||||||
decrementFileCountForLocalCacheDirectory(rem.getRequest(), rsrc);
|
decrementFileCountForLocalCacheDirectory(rem.getRequest(), rsrc);
|
||||||
|
LOG.info("Removed " + rsrc.getLocalPath() + " from localized cache");
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -193,8 +193,8 @@ public void handle(ResourceEvent event) {
|
|||||||
LOG.warn("Can't handle this event at current state", e);
|
LOG.warn("Can't handle this event at current state", e);
|
||||||
}
|
}
|
||||||
if (oldState != newState) {
|
if (oldState != newState) {
|
||||||
LOG.info("Resource " + resourcePath + " transitioned from "
|
LOG.info("Resource " + resourcePath + (localPath != null ?
|
||||||
+ oldState
|
"(->" + localPath + ")": "") + " transitioned from " + oldState
|
||||||
+ " to " + newState);
|
+ " to " + newState);
|
||||||
}
|
}
|
||||||
} finally {
|
} finally {
|
||||||
|
Loading…
Reference in New Issue
Block a user