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 <yueh...@lenovo.com> 于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/ >
