Repository: asterixdb Updated Branches: refs/heads/master ed5fc8172 -> 7a1174022
[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 <[email protected]> Integration-Tests: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Contrib: Jenkins <[email protected]> Reviewed-by: Till Westmann <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/7a117402 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/7a117402 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/7a117402 Branch: refs/heads/master Commit: 7a117402258433ac95b9c8e9d8ffb1ba036bb26c Parents: ed5fc81 Author: Xikui Wang <[email protected]> Authored: Fri Nov 17 10:28:33 2017 -0800 Committer: Xikui Wang <[email protected]> Committed: Fri Nov 17 17:03:28 2017 -0800 ---------------------------------------------------------------------- .../java/org/apache/hyracks/control/cc/executor/JobExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb/blob/7a117402/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/executor/JobExecutor.java ---------------------------------------------------------------------- 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 @@ public class JobExecutor { 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[]) {
