[FLINK-3055] [runtime] Remove redundant version of "Executionvertex.g…

…etSubTaskIndex()" This closes apache#1438
nltran · Dec 6, 2015 · 4003352 · 4003352
1 parent a1f4dd1
commit 4003352
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 6 deletions.
diff --git a/.../apache/flink/runtime/webmonitor/handlers/SubtaskExecutionAttemptAccumulatorsHandler.java b/.../apache/flink/runtime/webmonitor/handlers/SubtaskExecutionAttemptAccumulatorsHandler.java
@@ -46,7 +46,7 @@ public String handleRequest(Execution execAttempt, Map<String, String> params) t
 
  gen.writeStartObject();
 
- gen.writeNumberField("subtask", execAttempt.getVertex().getSubTaskIndex());
+ gen.writeNumberField("subtask", execAttempt.getVertex().getParallelSubtaskIndex());
  gen.writeNumberField("attempt", execAttempt.getAttemptNumber());
  gen.writeStringField("id", execAttempt.getAttemptId().toShortString());
 

diff --git a/...a/org/apache/flink/runtime/webmonitor/handlers/SubtaskExecutionAttemptDetailsHandler.java b/...a/org/apache/flink/runtime/webmonitor/handlers/SubtaskExecutionAttemptDetailsHandler.java
@@ -78,7 +78,7 @@ public String handleRequest(Execution execAttempt, Map<String, String> params) t
  JsonGenerator gen = JsonFactory.jacksonFactory.createJsonGenerator(writer);
 
  gen.writeStartObject();
- gen.writeNumberField("subtask", execAttempt.getVertex().getSubTaskIndex());
+ gen.writeNumberField("subtask", execAttempt.getVertex().getParallelSubtaskIndex());
  gen.writeStringField("status", status.name());
  gen.writeNumberField("attempt", execAttempt.getAttemptNumber());
  gen.writeStringField("host", locationString);

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
@@ -179,10 +179,6 @@ public String getTaskNameWithSubtaskIndex() {
  getTotalNumberOfParallelSubtasks());
  }
 
- public int getSubTaskIndex() {
- return subTaskIndex;
- }
-
  public int getTotalNumberOfParallelSubtasks() {
  return this.jobVertex.getParallelism();
  }