Hi Enric, It basically means the prioritized buffers can bypass all non-prioritized buffers at the input gate and get processed first. You may refer to https://issues.apache.org/jira/browse/FLINK-19026 for more details where it is firstly introduced.
Best, Zhanghao Chen ________________________________ From: Enric Ott <243816...@qq.com> Sent: Wednesday, July 10, 2024 18:02 To: user <user@flink.apache.org> Subject: Buffer Priority Hello,Community: I am puzzled by what the Priority means in Flink Buffer,it explains with example(as follows) in Buffer.java,but I still don't get what exactly is "it skipped buffers"。Could anyone give me a intuitive explanation? Thanks. /** Same as EVENT_BUFFER, but the event has been prioritized (e.g. it skipped buffers). */ PRIORITIZED_EVENT_BUFFER(false, true, false, true, false, false),
