Could not load the task's invokable class.

I am trying to run a Java flink streaming job (basic word count with Kafka) locally. But I am stuck with the following error. Any ideas on the cause of the error? Job execution switched to status RUNNING. 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(1/8) switched to SCHEDULED 10/29/

Re: Could not load the task's invokable class.

Hi Stephan, Thanx for the response. Actually I am using Maven and below are all Flink dependencies I have in my pom.xml file. / org.apache.flink flink-core 0.9.1 provided

Re: Flink execution time benchmark.

Hi rmetzger0, Thanx for the response. I didn't know that I had to register before I could receive responses for my posts. Now I am registered. But the problem is not resolved yet. I know it might not be intuitive to get execution time from a long running streaming job but it is possible to get to