Yingjie Cao created FLINK-17208:
-----------------------------------
Summary: Reduce redundant data available notification of
PipelinedSubpartition
Key: FLINK-17208
URL: https://issues.apache.org/jira/browse/FLINK-17208
Project: Flink
Issue Type: Improvement
Components: Runtime / Network
Affects Versions: 1.11.0
Reporter: Yingjie Cao
Fix For: 1.11.0
There are three scenarios that may lead to redundant data available
notifications for PipelinedSubpartition:
# Add a new BufferConsumer after an event;
# Finish the current subpartition;
# Flush an event buffer.
We can avoid these redundant data available notifications.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
