Re: Buffer Priority

2024-07-12 Thread Zhanghao Chen
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 ___

Re: Taskslots usage

2024-07-12 Thread Aleksandr Pilipenko
Hello Alexandre, Flink does not use TaskSlot per each task by default, but rather task slot will hold a slice of the entire pipeline (up to 1 subtasks of each operator, depending on the operator parallelism) [1]. So if your job parallelism is 1 - only a single task slot will be occupied. If you w

Re: Taskslots usage

2024-07-12 Thread Saurabh Singh
Hi Ky Alexandre, I would recommend reading this section which explains slot sharing b/w tasks. Link Quote - By default, Flink allows subtasks to share slots even if they are >