You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by af...@apache.org on 2015/12/18 19:12:31 UTC
reef git commit: [REEF-1064] Node-local evaluator requests don't
respect locality
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 <td...@cs.washington.edu>
Authored: Thu Dec 17 17:23:53 2015 -0800
Committer: Andrew Chung <af...@gmail.com>
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