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

Reply via email to