[jira] [Created] (FLINK-8674) Efficiently handle alwaysFlush case (0ms flushTimeout)

[Shang Yuanchun (Jira)]

Piotr Nowojski created FLINK-8674:
-------------------------------------

             Summary: Efficiently handle alwaysFlush case (0ms flushTimeout)
                 Key: FLINK-8674
                 URL: https://issues.apache.org/jira/browse/FLINK-8674
             Project: Flink
          Issue Type: Sub-task
            Reporter: Piotr Nowojski
            Assignee: Piotr Nowojski


Changes in data notifications introduced alongside BufferConsumer significantly degraded performance of 0ms flushTimeout.

 

Previously flushing after writing only record, effectively triggered only one data notification for the sub-partition/channel to which this record was written. With low latency improvements, this changed and flush is now triggering data notifications for all of the partitions. This can (and should) be easily fixed.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)