[
https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-11082:
-
Affects Version/s: (was: 1.6.3)
(was: 1.8.0)
> Fix the calculation of bac
[
https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-11082:
-
Description:
The backlog of subpartition should indicate how many buffers are consumable,
then the cons
[
https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-11082:
-
Summary: Fix the calculation of backlog in PipelinedSubpartition (was:
Increase backlog only if it is a
