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 <[email protected]>: > Flink socketTextStream received data using the TCP protocol. Is there any > way to get data using the UDP protocol? >
