Jiayi Liao created FLINK-16001: ---------------------------------- Summary: 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
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] [~zhuzh] -- This message was sent by Atlassian Jira (v8.3.4#803005)