Re: How the Async Exuecution Model improved the throughtput

2024-11-26 Thread Zakelly Lan
s before 2.0-preview just handle the state I/O with the > user thread?My gosh. > > > -- 原始邮件 -- > *发件人:* "Zakelly Lan" ; > *发送时间:* 2024年11月26日(星期二) 中午11:57 > *收件人:* "user"; > *主题:* Re: How the Async Exuecution Model improve

?????? How the Async Exuecution Model improved the throughtput

2024-11-25 Thread Enric Ott
Thank you,Zakelly. Seems that versions before 2.0-preview just handle the state I/O with the user thread?My gosh. --  -- ??: "Zake

Re: How the Async Exuecution Model improved the throughtput

2024-11-25 Thread Zakelly Lan
Hi Enric, The asynchronous state processing prevents the task thread from blocking at the state I/O and instead allows it to perform CPU operations for another input record in the meantime. Additionally, state I/Os can run in parallel, reducing the total I/O time. Therefore, it is suitable for the

How the Async Exuecution Model improved the throughtput

2024-11-25 Thread Enric Ott
Hello,Community:   I'm conducting experiments on flink-release-2.0-preview1,and I got puzzled that How the Async Exuecution Model achieved significant improvement on end to end throughput  in the scenarios of streaming state processing.The state access is relatively light weighted(in my personal