Zhu Zhu created FLINK-14811:
-------------------------------
Summary: Replace Java Streams with for-loops in vertex input
checking
Key: FLINK-14811
URL: https://issues.apache.org/jira/browse/FLINK-14811
Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Affects Versions: 1.10.0
Reporter: Zhu Zhu
Vertex input checking is invoked in lazily triggered scheduling by a FINISHED
vertex state update RPC or a {{scheduleOrUpdateConsumers}} RPC.
Java Streams is used in it, but it should be avoided since it is performance
critical code. See ref [1] and [2].
We should refactor these Java Streams to improve the performance, for both
legacy scheduler and NG schedulers.
cc [~sewen] [~gjy]
[1] [flink code style
guide|https://flink.apache.org/contributing/code-style-and-quality-java.html]
[2] [discussion & performance
test|https://issues.apache.org/jira/browse/FLINK-14735?focusedCommentId=16974209&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-16974209]
which compares the performance.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
