Hi, Kamal. The SplitEnumerator is contained in the SourceCoordinator. They are only used in JM.
Best, Hang Kamal Mittal via user <user@flink.apache.org> 于2023年8月1日周二 10:43写道： > 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 <ron9....@gmail.com> > *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 connector like TCP source in Flink main > repo. If you need this connector, you can try to implement it refer to the > FLIP-27 source docs > > > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/sources/ > > > > Best, > > Ron > > > > Shammon FY <zjur...@gmail.com> 于2023年7月27日周四 11:23写道： > > I cannot find any information about netty source in flink website and it > is not in the connector list[1], so I'm think that it is not supported by > flink community > > > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/overview/ > > > > Best, > > Shammon FY > > > > On Thu, Jul 27, 2023 at 10:53 AM Kamal Mittal <kamal.mit...@ericsson.com> > wrote: > > Hello Shammon, > > > > Yes socket text stream I am aware of but was thinking if something like as > ‘https://github.com/apache/bahir-flink/tree/master/flink-connector-netty > <https://protect2.fireeye.com/v1/url?k=31323334-501d5122-313273af-454445555731-ffc853ff875d9ed3&q=1&e=30c3fa9e-7c08-4486-8017-0d78c3c714ac&u=https%3A%2F%2Fgithub.com%2Fapache%2Fbahir-flink%2Ftree%2Fmaster%2Fflink-connector-netty>’ > is also supported by Flink? > > > > Rgds, > > Kamal > > > > *From:* Shammon FY <zjur...@gmail.com> > *Sent:* 27 July 2023 08:15 AM > *To:* Kamal Mittal <kamal.mit...@ericsson.com> > *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 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 < > user@flink.apache.org> wrote: > > Hello, > > > > Does flink provides netty connector for custom TCP source? > > > > Any documentation details please share? > > > > Rgds, > > Kamal > >
