Re: Buffer Priority

[Enric Ott]

Oh,it's designed for unaligned checkpoint.
Thanks,Zhanghao.




------------------ Original ------------------
From:                                                                           
                                             "Zhanghao Chen"                    
                                                                
<zhanghao.c...@outlook.com&gt;;
Date:&nbsp;Sat, Jul 13, 2024 01:01 PM
To:&nbsp;"Enric Ott"<243816...@qq.com&gt;;"user"<user@flink.apache.org&gt;;

Subject:&nbsp;Re: Buffer Priority



  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&nbsp;for more details where 
it is firstly introduced.
  
 
   Best,
 Zhanghao Chen
 
 
 
 
 From: Enric Ott <243816...@qq.com&gt;
 Sent: Wednesday, July 10, 2024 18:02
 To: user <user@flink.apache.org&gt;
 Subject: Buffer Priority &nbsp;
 
   Hello,Community:
 &nbsp; 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?
 &nbsp; 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),