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)