Xikui Wang has submitted this change and it was merged. Change subject: [ASTERIXDB-2164][HYR] Fix node assignment bug for unbounded task ......................................................................
[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]> --- M hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/executor/JobExecutor.java 1 file changed, 1 insertion(+), 1 deletion(-) Approvals: Anon. E. Moose #1000171: No violations found Till Westmann: Looks good to me, approved Jenkins: Verified; No violations found; No violations found; Verified 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[]) { -- To view, visit https://asterix-gerrit.ics.uci.edu/2148 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: merged Gerrit-Change-Id: I06e1b38bf74038d975a6dd17052e46e74fe1fc02 Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Xikui Wang <[email protected]> Gerrit-Reviewer: Anon. E. Moose #1000171 Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Till Westmann <[email protected]> Gerrit-Reviewer: Xikui Wang <[email protected]>
