Re: Flink netty connector for TCP source

2023-08-02 Thread Shammon FY
; > Rgds, > > Kamal > > > > *From:* Shammon FY > *Sent:* 03 August 2023 10:54 AM > *To:* Kamal Mittal > *Cc:* user@flink.apache.org > *Subject:* Re: Flink netty connector for TCP source > > > > Hi Kamal, > > > > I think it depends on yo

RE: Flink netty connector for TCP source

2023-08-02 Thread Kamal Mittal via user
ittal via user mailto:user@flink.apache.org>> Sent: 02 August 2023 08:02 AM To: Shammon FY mailto:zjur...@gmail.com>>; user@flink.apache.org<mailto:user@flink.apache.org> Subject: RE: Flink netty connector for TCP source Thanks Shammon. Purpose of opening server socket in Split

Re: Flink netty connector for TCP source

2023-08-02 Thread Shammon FY
l via user > *Sent:* 02 August 2023 08:02 AM > *To:* Shammon FY ; user@flink.apache.org > *Subject:* RE: Flink netty connector for TCP source > > > > Thanks Shammon. > > > > Purpose of opening server socket in Split Enumerator was that it has only > one inst

RE: Flink netty connector for TCP source

2023-08-02 Thread Kamal Mittal via user
Hello Shammon, Please have a look for below and share views. Rgds, Kamal From: Kamal Mittal via user Sent: 02 August 2023 08:02 AM To: Shammon FY ; user@flink.apache.org Subject: RE: Flink netty connector for TCP source Thanks Shammon. Purpose of opening server socket in Split Enumerator

RE: Flink netty connector for TCP source

2023-08-01 Thread Kamal Mittal via user
, Kamal From: Shammon FY Sent: 02 August 2023 07:48 AM To: Kamal Mittal ; user@flink.apache.org Subject: Re: Flink netty connector for TCP source Hi Kamal, It confuses me a little that what's the purpose of opening a server socket in SplitEnumerator? Currently there will be only one SplitEnumerator

Re: Flink netty connector for TCP source

2023-08-01 Thread Shammon FY
is not correct. > > > > Rgds, > > Kamal > > > > *From:* Hang Ruan > *Sent:* 01 August 2023 08:55 AM > *To:* Kamal Mittal > *Cc:* liu ron ; user@flink.apache.org > *Subject:* Re: Flink netty connector for TCP source > > > > Hi, Kamal.

RE: Flink netty connector for TCP source

2023-07-31 Thread Kamal Mittal via user
is applicable for source operator and not for split enumerator? Please correct me if above understanding is not correct. Rgds, Kamal From: Hang Ruan Sent: 01 August 2023 08:55 AM To: Kamal Mittal Cc: liu ron ; user@flink.apache.org Subject: Re: Flink netty connector for TCP source Hi, Kamal

Re: Flink netty connector for TCP source

2023-07-31 Thread Hang Ruan
to execute on Job Manager rather than at > Task manager? > > > > *From:* liu ron > *Sent:* 31 July 2023 10:06 PM > *To:* user@flink.apache.org > *Subject:* Re: Flink netty connector for TCP source > > > > Hi, Kamal > > Currently, we don't provide the

RE: Flink netty connector for TCP source

2023-07-31 Thread Kamal Mittal via user
Thanks. I looked at the link for custom data sources, one query here that how to make sure for Split enumerator to execute on Job Manager rather than at Task manager? From: liu ron Sent: 31 July 2023 10:06 PM To: user@flink.apache.org Subject: Re: Flink netty connector for TCP source Hi

Re: Flink netty connector for TCP source

2023-07-31 Thread liu ron
ache/bahir-flink/tree/master/flink-connector-netty’ >> is also supported by Flink? >> >> >> >> Rgds, >> >> Kamal >> >> >> >> *From:* Shammon FY >> *Sent:* 27 July 2023 08:15 AM >> *To:* Kamal Mittal >> *Cc:* user@flink.a

Re: Flink netty connector for TCP source

2023-07-26 Thread Shammon FY
mal > > > > *From:* Shammon FY > *Sent:* 27 July 2023 08:15 AM > *To:* Kamal Mittal > *Cc:* user@flink.apache.org > *Subject:* Re: Flink netty connector for TCP source > > > > Hi Kamal, > > > > There's socket text stream in `DataStream` and you can

RE: Flink netty connector for TCP source

2023-07-26 Thread Kamal Mittal via user
Subject: Re: Flink netty connector for TCP source Hi Kamal, There's socket text stream in `DataStream` and you can refer to [1] for more details. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/overview/#example-program Best, Shammon FY On Wed, Jul 26, 2023 at 4

Re: Flink netty connector for TCP source

2023-07-26 Thread Shammon FY
Hi Kamal, There's socket text stream in `DataStream` and you can refer to [1] for more details. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/overview/#example-program Best, Shammon FY On Wed, Jul 26, 2023 at 4:26 PM Kamal Mittal via user wrote: > Hello, > > >