[ https://issues.apache.org/jira/browse/FLINK-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061775#comment-17061775 ]
Jiayi Liao commented on FLINK-16001: ------------------------------------ [~gjy] You're right that this doesn't help the performance. I'm convinced. I'll try to improve performance from other places and thanks for your detailed guidance and explanation :) Closing this. > Avoid using Java Streams in construction of ExecutionGraph > ---------------------------------------------------------- > > Key: FLINK-16001 > URL: https://issues.apache.org/jira/browse/FLINK-16001 > Project: Flink > Issue Type: Improvement > Components: Runtime / Coordination > Affects Versions: 1.10.0 > Reporter: Jiayi Liao > Priority: Major > Attachments: benchmark.csv > > > I think we should avoid {{Java Streams}} in construction of > {{ExecutionGraph}} like function {{toPipelinedRegionsSet}} in > {{PipelinedRegionComputeUtil}} because the job submission is definitely > performance sensitive, especially when {{distinctRegions}} has a large > cardinality. > Also includes some other places in package > {{org.apache.flink.runtime.executiongraph}} > cc [~trohrmann] [~gjy] [~zhuzh] -- This message was sent by Atlassian Jira (v8.3.4#803005)