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
