yunfengzhou-hub commented on code in PR #23944:
URL: https://github.com/apache/flink/pull/23944#discussion_r1429556103
##########
flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java:
##########
@@ -153,6 +154,8 @@ public class JobGraphGenerator implements Visitor<PlanNode>
{
private final boolean useLargeRecordHandler;
+ private final Map<String, String> parallelismOverrides;
Review Comment:
Thanks for pointing this out. It seems that neither `JobGraphGenerator` nor
`StreamingJobGraphGenerator` has applied this logic. I'll move this to
FlinkPipelineTranslationUtil.getJobGraph, which helps to apply this logic
regardless of Plan or StreamGraph.
--
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]
