zhijiangW commented on a change in pull request #8529: [FLINK-12603][network]
Remove getOwningTaskName method from InputGate
URL: https://github.com/apache/flink/pull/8529#discussion_r290201733
##########
File path: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java
##########
@@ -132,11 +122,67 @@ public String getTaskNameWithSubtasks() {
return this.taskNameWithSubtasks;
}
+ /**
+ * Returns the name of the task, appended with the subtask indicator
and execution attempt id.
+ *
+ * @return The name of the task, with subtask indicator and execution
id.
+ */
+ public String getTaskNameWithSubtaskAndID() {
+ return taskNameWithSubtaskAndID;
+ }
+
/**
* Returns the allocation id for where this task is executed.
* @return the allocation id for where this task is executed.
*/
public String getAllocationIDAsString() {
return allocationIDAsString;
}
+
+ //
------------------------------------------------------------------------
+ // Factory Utilities
+ //
------------------------------------------------------------------------
+
+ public static TaskInfo create(
+ String taskName,
+ int maxNumberOfParallelSubtasks,
+ int numberOfParallelSubtasks,
+ int subtaskIndex,
+ int attemptNumber,
+ String attemptIDAsString,
Review comment:
I am not sure the history consideration of introducing
`allocationIDAsString` here. If we think it is not right thing to do, then I
could avoid following this way.
In addition, do you think I should refactor the way of
`allocationIDAsString` in a hotfix commit?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
