[jira] [Commented] (FLINK-11082) Fix the calculation of backlog in PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880499#comment-16880499 ] zhijiang commented on FLINK-11082: -- Yes, I also thought it was not an issue. > Fix the

[jira] [Commented] (FLINK-11082) Fix the calculation of backlog in PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880486#comment-16880486 ] Piotr Nowojski commented on FLINK-11082: As [~NicoK] wrote, I think this shouldn

[jira] [Commented] (FLINK-11082) Fix the calculation of backlog in PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880476#comment-16880476 ] Nico Kruber commented on FLINK-11082: - Yes, [~zjwang] - nonetheless, the floating bu

[jira] [Commented] (FLINK-11082) Fix the calculation of backlog in PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880427#comment-16880427 ] zhijiang commented on FLINK-11082: -- [~pnowojski], if the requested floating buffers are

[jira] [Commented] (FLINK-11082) Fix the calculation of backlog in PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880241#comment-16880241 ] Piotr Nowojski commented on FLINK-11082: [~NicoK] reminded me that this might st