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