?????? checkpoint upload 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.




------------------ ???????? ------------------
??????:                                                                         
                                               "Yanfei Lei"                     
                                                               
<fredia...@gmail.com&gt;;
????????:&nbsp;2024??7??30??(??????) ????5:15
??????:&nbsp;"Enric Ott"<243816...@qq.com&gt;;
????:&nbsp;"user"<user@flink.apache.org&gt;;
????:&nbsp;Re: checkpoint upload thread



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.java#L443
[2] 
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java#L716

Enric Ott <243816...@qq.com&gt; ??2024??7??30?????? 11:11??????
&gt;
&gt; Hi,Community:
&gt;&nbsp;&nbsp; Does Flink upload states and inflight buffers within the same 
opratorchain using the same connection (instead of per connection per operator)?



-- 
Best,
Yanfei