Repository: reef Updated Branches: refs/heads/master 6338420b5 -> d923b4b34
[REEF-1064] Node-local evaluator requests don't respect locality This addressed the issue by * Set `relaxLocality` parameter to `AMRMClient.ContainerRequest()` to `false` if a node name is specified in `EvaluatorRequest` JIRA: [REEF-1064] https://issues.apache.org/jira/browse/REEF-1064 Pull Request: Closes #745 Project: http://git-wip-us.apache.org/repos/asf/reef/repo Commit: http://git-wip-us.apache.org/repos/asf/reef/commit/d923b4b3 Tree: http://git-wip-us.apache.org/repos/asf/reef/tree/d923b4b3 Diff: http://git-wip-us.apache.org/repos/asf/reef/diff/d923b4b3 Branch: refs/heads/master Commit: d923b4b34c63620e8f897f90f2876cae14d57091 Parents: 6338420 Author: Tobin Baker <[email protected]> Authored: Thu Dec 17 17:23:53 2015 -0800 Committer: Andrew Chung <[email protected]> Committed: Fri Dec 18 10:11:38 2015 -0800 ---------------------------------------------------------------------- .../reef/runtime/common/driver/EvaluatorRequestorImpl.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/reef/blob/d923b4b3/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/EvaluatorRequestorImpl.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/EvaluatorRequestorImpl.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/EvaluatorRequestorImpl.java index 78e4d28..e433513 100644 --- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/EvaluatorRequestorImpl.java +++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/EvaluatorRequestorImpl.java @@ -91,6 +91,10 @@ public final class EvaluatorRequestorImpl implements EvaluatorRequestor { relaxLocality = false; } } + // if the user specified any node, then we assume they do not want to relax locality + if (!req.getNodeNames().isEmpty()) { + relaxLocality = false; + } try (LoggingScope ls = loggingScopeFactory.evaluatorSubmit(req.getNumber())) { final ResourceRequestEvent request = ResourceRequestEventImpl
