You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/11/19 19:54:11 UTC
flink git commit: [hotfix] [core] Fix assignment of strictly local
splits to host instances
Repository: flink
Updated Branches:
refs/heads/release-0.10 8f3f56b42 -> 076bb0a2f
[hotfix] [core] Fix assignment of strictly local splits to host instances
This closes #1345
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/076bb0a2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/076bb0a2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/076bb0a2
Branch: refs/heads/release-0.10
Commit: 076bb0a2fed30c476b21df40474a1d49b0e941a6
Parents: 8f3f56b
Author: qingmeng.wyh <qi...@taobao.com>
Authored: Wed Nov 11 15:40:19 2015 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Nov 19 19:53:14 2015 +0100
----------------------------------------------------------------------
.../apache/flink/runtime/executiongraph/ExecutionJobVertex.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/076bb0a2/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
index 53d94d7..1d4be14 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
@@ -310,7 +310,7 @@ public class ExecutionJobVertex implements Serializable {
pos = 0;
assignments.put(host, 0);
} else {
- assignments.put(host, pos + 1 % instancesOnHost.size());
+ assignments.put(host, (pos + 1) % instancesOnHost.size());
}
v.setLocationConstraintHosts(Collections.singletonList(instancesOnHost.get(pos)));