In JobGraph, does an IntermediateDataSet contain multiple JobEdges?

[yuehan1]

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/

[Zhu Zhu]

What you obsessed is right. At the moment, one IntermediateDataSet can have one only consumer job edge in production code path.

Thanks,

Zhu Zhu

yuehan1 <[hidden email]> 于2020年8月4日周二 下午5:14写道：

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/