Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r178824035
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java ---
@@ -107,4 +131,12 @@ public int getAttemptNumber() {
public String getTaskNameWithSubtasks() {
return this.taskNameWithSubtasks;
}
+
+ /**
+ * Returns the allocation id for where this task is executed.
+ * @return the allocation id for where this task is executed.
+ */
+ public String getAllocationID() {
--- End diff --
Hmm, what about testing it a bit more indirectly, by removing the
checkpoint files on the DFS. Then you can only recover if you recover locally.
Or by querying the REST interface? We might have to add the information to the
`VertexTaskDetail`.
Otherwise, we start mixing concerns and expose unnecessary information to
the user via the `AbstractRuntimeUDFContext`. Moreover, not every function has
access to this information right now. For example the
`RichAsyncFunctionRuntimeContext` does not expose it.
---
