Re: Reading byte[] from socket

Hi Paolo, have a look at SocketTextStreamFunction [1] which is internally used when StreamExecutionEnviornment.socketTextStream() is called. Best, Fabian [1] https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextS

Reading byte[] from socket

Hi, I would like to read a stream of byte[] from a socket. I know the "writeToSocket" function that allows you to specify a serialization schema to write your stream. I would like to do the same but for reading, specifying a deserialization schema that allows me to retrieve a stream of the class