You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by xi...@apache.org on 2017/11/18 01:05:23 UTC
asterixdb git commit: [ASTERIXDB-2164][HYR] Fix node assignment bug
for unbounded task
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 <je...@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <je...@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Contrib: Jenkins <je...@fulliautomatix.ics.uci.edu>
Reviewed-by: Till Westmann <ti...@apache.org>
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 <xk...@gmail.com>
Authored: Fri Nov 17 10:28:33 2017 -0800
Committer: Xikui Wang <xk...@gmail.com>
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[]) {