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/04/06 17:49:39 UTC
[6/7] flink git commit: [runtime] Fix bug that deploys to wrong
target TaskManager slot
[runtime] Fix bug that deploys to wrong target TaskManager slot
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/adc85301
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/adc85301
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/adc85301
Branch: refs/heads/master
Commit: adc85301cfb25cedce996d91f5aae69a2c597879
Parents: 43c080a
Author: Stephan Ewen <se...@apache.org>
Authored: Mon Apr 6 14:50:11 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Apr 6 15:30:46 2015 +0200
----------------------------------------------------------------------
.../org/apache/flink/runtime/executiongraph/ExecutionVertex.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/adc85301/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java
index 1b91089..e7e019f 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java
@@ -599,7 +599,7 @@ public class ExecutionVertex implements Serializable {
return new TaskDeploymentDescriptor(getJobId(), getJobvertexId(), executionId, getTaskName(),
subTaskIndex, getTotalNumberOfParallelSubtasks(), getExecutionGraph().getJobConfiguration(),
jobVertex.getJobVertex().getConfiguration(), jobVertex.getJobVertex().getInvokableClassName(),
- producedPartitions, consumedPartitions, jarFiles, targetSlot.getSlotNumber(), operatorState);
+ producedPartitions, consumedPartitions, jarFiles, targetSlot.getRoot().getSlotNumber(), operatorState);
}
// --------------------------------------------------------------------------------------------