[jira] [Created] (FLINK-22573) AsyncIO can timeout elements after completion

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22573) AsyncIO can timeout elements after completion

Shang Yuanchun (Jira)
Arvid Heise created FLINK-22573:
-----------------------------------

             Summary: AsyncIO can timeout elements after completion
                 Key: FLINK-22573
                 URL: https://issues.apache.org/jira/browse/FLINK-22573
             Project: Flink
          Issue Type: Bug
          Components: API / DataStream
    Affects Versions: 1.12.3, 1.13.0, 1.11.3, 1.14.0
            Reporter: Arvid Heise
            Assignee: Arvid Heise


AsyncIO emits completed elements over the mailbox at which any timer is also canceled. However, if the mailbox cannot process (heavy backpressure), it may be that the timer still triggers on a completed element.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)