IntermediateDataSet.java has a JobEdge list named consumers. In which case, an IntermediateDataSet contains multiple JobEdge. I read the code, it seems that an IntermediateDataSet can only have one JobEdge
// IntermediateDataSet.java private final List<JobEdge> consumers = new ArrayList<JobEdge>(); thanks for your reply -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
