Hi Enric, Sorry for the confusion, I mean "It can be done theoretically, and it depends on the specific implementation of the file system client in fact."
I think there are two ways to let different tasks share a connection (In other words: "socket"): 1. Share one *Output Stream*; 2. Use different Output Streams, but those OutputStreams share one underlying socket(which is implemented by the specific file system client). Back to Flink, currently different tasks do not share the output streams, but I am not sure whether the underlying sockets are shared. Enric Ott <243816...@qq.com> 于2024年8月1日周四 10:04写道： > > 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>; > 发送时间: 2024年7月30日(星期二) 下午5:15 > 收件人: "Enric Ott"<243816...@qq.com>; > 抄送: "user"<user@flink.apache.org>; > 主题: 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> 于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 -- Best, Yanfei
