You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Soheil Pourbafrani <so...@gmail.com> on 2018/08/13 08:04:55 UTC

Flink socketTextStream UDP connection

Flink socketTextStream received data using the TCP protocol. Is there any
way to get data using the UDP protocol?

Re: Flink socketTextStream UDP connection

Posted by Soheil Pourbafrani <so...@gmail.com>.

Thank you for the information.

On Mon, Aug 13, 2018 at 1:51 PM Fabian Hueske <fh...@gmail.com> wrote:

> Hi,
>
> ExecutionEnvironment.socketTextStream is deprecated and it is very likely
> that it will be removed because of its limited use.
> I would recommend to have at the implementation of the SourceFunction [1]
> and adapt it to your needs.
>
> Best, Fabian
>
> [1]
> https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
>
> 2018-08-13 10:04 GMT+02:00 Soheil Pourbafrani <so...@gmail.com>:
>
>> Flink socketTextStream received data using the TCP protocol. Is there any
>> way to get data using the UDP protocol?
>>
>
>

Re: Flink socketTextStream UDP connection

Posted by Fabian Hueske <fh...@gmail.com>.

Hi,

ExecutionEnvironment.socketTextStream is deprecated and it is very likely
that it will be removed because of its limited use.
I would recommend to have at the implementation of the SourceFunction [1]
and adapt it to your needs.

Best, Fabian

[1]
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java

2018-08-13 10:04 GMT+02:00 Soheil Pourbafrani <so...@gmail.com>:

> Flink socketTextStream received data using the TCP protocol. Is there any
> way to get data using the UDP protocol?
>