flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sjk <shijinkui...@163.com>
Subject [DISCUSS] schedule for execution from different list of ExecutionJobVertex
Date Fri, 30 Dec 2016 10:03:05 GMT
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
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message