[runtime] Fix bug that deploys to wrong target TaskManager slot

VonRosenchild · Apr 6, 2015 · adc8530 · adc8530
1 parent 43c080a
commit adc8530
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -599,7 +599,7 @@ TaskDeploymentDescriptor createDeploymentDescriptor(
  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);
  }
 
  // --------------------------------------------------------------------------------------------