Hi, all
On [FLINK-1425][1] add executeMode supporting by Ufuk Celebi .
I want to know why two loop using different list object: task.value() and
getVerticesTopologically().
task and getVerticesTopologically() all filled in attachJobGraph function:
public void attachJobGraph(List<JobVertex> topologiallySorted) throws
JobException {
...
ExecutionJobVertex previousTask = this.tasks.putIfAbsent(jobVertex.getID(),
ejv);
...
this.verticesInCreationOrder.add(ejv);
…
}
At the moment of before starting run ExecutionJobVertex, are the task.value and
getVerticesTopologically having same elements?
[1]
https://github.com/apache/flink/commit/ad31f611150b4b95147dca26932b7ad11bb4b920#diff-db400d27f89469eca0a85a5e9b564bc7L326
<https://github.com/apache/flink/commit/ad31f611150b4b95147dca26932b7ad11bb4b920#diff-db400d27f89469eca0a85a5e9b564bc7L326>
Thanks
Best regards
from Jinkui Shi