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)
