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> 于2024年7月30日周二 11:11写道： > > Hi,Community: > Does Flink upload states and inflight buffers within the same opratorchain > using the same connection (instead of per connection per operator)? -- Best, Yanfei
