Flink socketTextStream UDP connection

[Soheil Pourbafrani]

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

[Fabian Hueske-2]

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 <[hidden email]>:

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

[Soheil Pourbafrani]

Thank you for the information. 

On Mon, Aug 13, 2018 at 1:51 PM Fabian Hueske <[hidden email]> 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 <[hidden email]>:

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