asterixdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xi...@apache.org
Subject asterixdb git commit: [ASTERIXDB-2164][HYR] Fix node assignment bug for unbounded task
Date Sat, 18 Nov 2017 01:05:23 GMT
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 <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>


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 <xkkwww@gmail.com>
Authored: Fri Nov 17 10:28:33 2017 -0800
Committer: Xikui Wang <xkkwww@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[]) {


Mime
View raw message