Customer inputformat

Hi, I created a custom input format. Idea behind this is to read all binary files from a directory and use each file as it's own split. Each split is read as one whole record. When I run it in flink I don't get any error but I am not seeing any output from .print. Am I missing something? *p

multiple streams with multiple actions - proper way?

Hello Flink People :-) I am trying to get my head around flink - is it a supported use case to register multiple streams with possibly more than one transformation / action per stream? def main(args: Array[String]): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment v

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