| commit | 7a117402258433ac95b9c8e9d8ffb1ba036bb26c | [log] [tgz] |
|---|---|---|
| author | Xikui Wang <xkkwww@gmail.com> | Fri Nov 17 10:28:33 2017 -0800 |
| committer | Xikui Wang <xkkwww@gmail.com> | Fri Nov 17 17:03:28 2017 -0800 |
| tree | 313bf6f77969b213d8548838b6d98d83c0da5b95 | |
| parent | ed5fc81724d31abbc92eeb60ded2518b91544ad0 [diff] |
[ASTERIXDB-2164][HYR] Fix node assignment bug for unbounded task - user model changes: no - storage format changes: no - interface changes: no Details: The upper bound of node selection is mistakenly set to 1. Change that to the size of live nodes can fix the issue. Change-Id: I06e1b38bf74038d975a6dd17052e46e74fe1fc02 Reviewed-on: https://asterix-gerrit.ics.uci.edu/2148 Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Till Westmann <tillw@apache.org>
diff --git a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/executor/JobExecutor.java b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/executor/JobExecutor.java index 0b69024..01201a6 100644 --- a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/executor/JobExecutor.java +++ b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/executor/JobExecutor.java
@@ -447,7 +447,7 @@ Object location = solver.getValue(pLocationExpr); if (location == null) { // pick any - nodeId = liveNodes.toArray(new String[liveNodes.size()])[random.nextInt(1) % liveNodes.size()]; + nodeId = liveNodes.toArray(new String[liveNodes.size()])[random.nextInt(liveNodes.size())]; } else if (location instanceof String) { nodeId = (String) location; } else if (location instanceof String[]) {