?????? checkpoint upload thread

2024-08-01 Thread Enric Ott
Thanks for the clarification,Yanfei.And I will dig it deeper later. --  -- ??: "Yanfei Lei"

Re: checkpoint upload thread

2024-08-01 Thread Yanfei Lei
d but with applied probability? > > Thanks. > > > -- 原始邮件 -- > 发件人: "Yanfei Lei" ; > 发送时间: 2024年7月30日(星期二) 下午5:15 > 收件人: "Enric Ott"<243816...@qq.com>; > 抄送: "user"; > 主题: Re: checkpoint upload thread > > Hi Enric

?????? checkpoint upload thread

2024-07-31 Thread Enric Ott
Hi,Yanfei:   What do you mean by using the word possible in statment it is possible to use the same connection for an operator chain? Meaning able to be done but not applied in fact? Or actually applied but with applied probability?   Thanks. --  -- ??

Re: checkpoint upload thread

2024-07-30 Thread Yanfei Lei
Hi Enric, If I understand correctly, one subtask would use one `asyncOperationsThreadPool`[1,2], it is possible to use the same connection for an operator chain. [1] https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask

checkpoint upload thread

2024-07-29 Thread Enric Ott
Hi,Community:   Does Flink upload states and inflight buffers within the same opratorchain using the same connection (instead of per connection per operator)?