Unsubscribe

Hi, I would like to unsubscribe from the mailing list. Best, Paolo

Measure Job Execution Time

I would like to measure exactly the job execution time when executing a job in standalone mode. The result provided by the web interface is not accurate enough. I have seen the answer provided at this link https://stackoverflow.com/questions/34243365/measure-job-execution-time-in-flink , but it see

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

Class not found when deserializing

Hi, I am trying to write and read in a Kafka topic a user-defined class (that implements serializable, and all the fields are serializable). Everything works fine when I am executing the program in the IDE or with the mvn exec command. When I try to execute the program in standalone mode I get the

Latency Measurement

arrived and the system can aggregate them. Now I perform the map operation and we emit the output record at time x+15. I would like to obtain 15 as latency. Do you have any suggestion on how to proceed? Thanks for your time, Paolo Cristofanelli

Kafka Connectors

Hi, I am following the basic steps to implement a consumer and a producer with Kafka for Flink. My Flink version is 1.2.0, the Kafka's one is 0.10.2.0, so in my pom.xml I will add the : org.apache.flink flink-connector-kafka-0.10_2.10 1.2.0 The problem is that if I run the program with maven

Latency and Throughput

Hi, it is my first question that I am asking in this mailing list, so I hope you would forgive me if I miss something. I have started using flink recently, and now I would like to compute some statistics, like throughput and latency, for my programs. I was reading this URL from the documentation (