[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Flink socketTextStream UDP connection


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 <soheil.ir08@xxxxxxxxx>:
Flink socketTextStream received data using the TCP protocol. Is there any way to get data using the UDP protocol?