reswqa commented on code in PR #22674:
URL: https://github.com/apache/flink/pull/22674#discussion_r1211218197
##########
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphBuilder.java:
##########
@@ -143,7 +147,8 @@ public static DefaultExecutionGraph buildGraph(
executionJobVertexFactory,
jobGraph.getJobStatusHooks(),
markPartitionFinishedStrategy,
- nonFinishedHybridPartitionShouldBeUnknown);
+ nonFinishedHybridPartitionShouldBeUnknown,
Review Comment:
Thanks for inviting me. I didn't carefully check the code, but I think they
can be merged into one auxiliary class. If we plan to do this refactoring,
other task deployment related fields (if any) should also be merged in.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
