gaoyunhaii commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r872318377
########## flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java: ########## @@ -142,6 +142,12 @@ public class JobVertex implements java.io.Serializable { */ private String resultOptimizerProperties; + /** + * Optional, the intermediateDataSetId of the cached intermediate dataset that the job vertex + * consumes. + */ + @Nullable private final IntermediateDataSetID intermediateDataSetID; Review Comment: Each JobVertex may consumes multiple `IntermediateDataSet`, thus I think it is not sufficient to bookkeep one id here? Perhaps like two-inputs tasks (join) or multiple-inputs tasks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org