Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1386#discussion_r46773693
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -120,16 +121,9 @@
/** The execution attempt of the parallel subtask */
private final ExecutionAttemptID executionId;
- /** The index of the parallel subtask, in [0, numberOfSubtasks) */
- private final int subtaskIndex;
+ /** TaskInfo object for this task */
+ private final TaskInfo taskInfo;
- /** The number of parallel subtasks for the
JobVertex/ExecutionJobVertex that this task belongs to */
- private final int parallelism;
-
- /** The name of the task */
- private final String taskName;
-
- /** The name of the task, including the subtask index and the
parallelism */
private final String taskNameWithSubtask;
--- End diff --
This field is also subsumed by the `TaskInfo`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
