RE: Flink operator task opens threads internally

2023-08-05 Thread Kamal Mittal via user
gt;>; Paul Lam mailto:paullin3...@gmail.com>> Cc: user@flink.apache.org<mailto:user@flink.apache.org> Subject: RE: Flink operator task opens threads internally Hello, I hope you have the context of use case clear now as described in below mail as well as here again – Flink application w

Re: Flink operator task opens threads internally

2023-08-05 Thread liu ron
pplication is running over K8s environment. > > > > Do let me know please that it is ok to open multiple threads for accepting > client socket connections inside flink application? > > > > Rgds, > > Kamal > > > > *From:* Kamal Mittal via user > *Sent:*

RE: Flink operator task opens threads internally

2023-08-04 Thread Kamal Mittal via user
Hello, Can you please share views for below? Rgds, Kamal From: Kamal Mittal Sent: 04 August 2023 11:19 AM To: Kamal Mittal ; Paul Lam Cc: user@flink.apache.org Subject: RE: Flink operator task opens threads internally Hello, I hope you have the context of use case clear now as described in

RE: Flink operator task opens threads internally

2023-08-03 Thread Kamal Mittal via user
application? Rgds, Kamal From: Kamal Mittal via user Sent: 03 August 2023 09:27 AM To: Paul Lam Cc: user@flink.apache.org Subject: RE: Flink operator task opens threads internally Hello, We have a client sending TCP traffic towards Flink application and to support that there is server socket

RE: Flink operator task opens threads internally

2023-08-02 Thread Kamal Mittal via user
flink task slot. Rgds, KAmal From: Paul Lam Sent: 03 August 2023 08:59 AM To: Kamal Mittal Cc: user@flink.apache.org Subject: Re: Flink operator task opens threads internally Hi Kamal, It’s okay if you don’t mind the data order. But it’s not very commonly seen to accept client sockets from

Re: Flink operator task opens threads internally

2023-08-02 Thread Paul Lam
Hi Kamal, It’s okay if you don’t mind the data order. But it’s not very commonly seen to accept client sockets from Flink jobs, as the socket server address is dynamic and requires service discovery. Would you like to share more about the background? Best, Paul Lam > 2023年8月3日 10:26,Kamal Mit

RE: Flink operator task opens threads internally

2023-08-02 Thread Kamal Mittal via user
Hello Community, Please share views for the below mail. Rgds, Kamal From: Kamal Mittal via user Sent: 02 August 2023 08:19 AM To: user@flink.apache.org Subject: Flink operator task opens threads internally Hello Community, I have a operator pipeline like as below, is it ok if "source" task op