;
> 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
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
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
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
,
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
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.
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
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
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
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
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
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
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,
>
>
>
13 matches
Mail list logo