flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [6/7] flink git commit: [runtime] Fix bug that deploys to wrong target TaskManager slot
Date Mon, 06 Apr 2015 15:49:39 GMT
[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 <sewen@apache.org>
Authored: Mon Apr 6 14:50:11 2015 +0200
Committer: Stephan Ewen <sewen@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);
 	}
 
 	// --------------------------------------------------------------------------------------------


Mime
View raw message