[flink] 04/05: [FLINK-12883][runtime] Add getID() to ExecutionVertex

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 2f5fc239ee7712e02f3f3ebfc0a991acdcf6e3cf
Author: Gary Yao <g...@apache.org>
AuthorDate: Wed Jun 19 14:45:53 2019 +0200

    [FLINK-12883][runtime] Add getID() to ExecutionVertex
---
 .../org/apache/flink/runtime/executiongraph/ExecutionVertex.java  | 8 ++++++++
 1 file changed, 8 insertions(+)

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 a12d198..5fc0b72 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
@@ -39,6 +39,7 @@ import 
org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup;
 import 
org.apache.flink.runtime.jobmanager.scheduler.LocationPreferenceConstraint;
 import org.apache.flink.runtime.jobmaster.LogicalSlot;
 import org.apache.flink.runtime.jobmaster.slotpool.SlotProvider;
+import org.apache.flink.runtime.scheduler.strategy.ExecutionVertexID;
 import org.apache.flink.runtime.taskmanager.TaskManagerLocation;
 import org.apache.flink.runtime.util.EvictingBoundedList;
 import org.apache.flink.util.ExceptionUtils;
@@ -83,6 +84,8 @@ public class ExecutionVertex implements 
AccessExecutionVertex, Archiveable<Archi
 
        private final int subTaskIndex;
 
+       private final ExecutionVertexID executionVertexId;
+
        private final EvictingBoundedList<ArchivedExecution> priorExecutions;
 
        private final Time timeout;
@@ -142,6 +145,7 @@ public class ExecutionVertex implements 
AccessExecutionVertex, Archiveable<Archi
 
                this.jobVertex = jobVertex;
                this.subTaskIndex = subTaskIndex;
+               this.executionVertexId = new 
ExecutionVertexID(jobVertex.getJobVertexId(), subTaskIndex);
                this.taskNameWithSubtask = String.format("%s (%d/%d)",
                                jobVertex.getJobVertex().getName(), 
subTaskIndex + 1, jobVertex.getParallelism());
 
@@ -228,6 +232,10 @@ public class ExecutionVertex implements 
AccessExecutionVertex, Archiveable<Archi
                return this.subTaskIndex;
        }
 
+       public ExecutionVertexID getID() {
+               return executionVertexId;
+       }
+
        public int getNumberOfInputs() {
                return this.inputEdges.length;
        }