Thanks for the clarification,Yanfei.And I will dig it deeper later.
-- --
??:
"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
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.
-- --
??
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
Hi,Community:
Does Flink upload states and inflight buffers within the same
opratorchain using the same connection (instead of per connection per operator)?