You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/08/22 19:01:00 UTC

[jira] [Created] (FLINK-19026) Improve threading model of Unaligner

Arvid Heise created FLINK-19026:
-----------------------------------

             Summary: Improve threading model of Unaligner
                 Key: FLINK-19026
                 URL: https://issues.apache.org/jira/browse/FLINK-19026
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Network
    Affects Versions: 1.12.0
            Reporter: Arvid Heise
            Assignee: Arvid Heise


Currently, netty threads and task thread are both accessing Unaligner. Netty thread access it indirectly through BufferReceivedListener. Thus, we need some costly synchronization and weaken the threading model of the Unaligner.

One possibility would be to introduce priority buffers to the InputGates, which overtake other buffers and also are always processable (e.g. they bypass non-blocking outputs).



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