Hi! You probably miss some jars in your classpath. Usually Maven/SBT resolve that automatically, so I assume you are manually constructing the classpath here?
For this particular error, you probably miss the "flink-streaming-core" (0.9.1) / "flink-streaming-java" (0.10) in your classpath. I would recommend to use the 0.10 version (the latest release candidate) for your experiments. Stephan On Mon, Nov 2, 2015 at 10:10 AM, Saleh <e106...@hotmail.com> wrote: > 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/2015 11:15:54 Custom Source -> Flat Map -> Map(1/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(2/8) switched to > SCHEDULED > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(2/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(3/8) switched to > SCHEDULED > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(3/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(4/8) switched to > SCHEDULED > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(4/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(5/8) switched to > SCHEDULED > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(5/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(6/8) switched to > SCHEDULED > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(6/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(7/8) switched to > SCHEDULED > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(7/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(8/8) switched to > SCHEDULED > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(8/8) switched to > DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(1/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(1/8) switched to DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(2/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(2/8) switched to DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(3/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(3/8) switched to DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(4/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(4/8) switched to DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(5/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(5/8) switched to DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(6/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(6/8) switched to DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(7/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(7/8) switched to DEPLOYING > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(8/8) switched to SCHEDULED > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(8/8) switched to DEPLOYING > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(5/8) switched to > FAILED > java.lang.Exception: Could not load the task's invokable class. > at > > org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:696) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:450) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.ClassCastException: class > org.apache.flink.streaming.runtime.tasks.SourceStreamTask > at java.lang.Class.asSubclass(Class.java:3404) > at > > org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:693) > ... 2 more > > 10/29/2015 11:15:54 Custom Source -> Flat Map -> Map(2/8) switched to > FAILED > java.lang.Exception: Could not load the task's invokable class. > at > > org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:696) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:450) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.ClassCastException: class > org.apache.flink.streaming.runtime.tasks.SourceStreamTask > at java.lang.Class.asSubclass(Class.java:3404) > at > > org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:693) > ... 2 more > > 10/29/2015 11:15:54 Job execution switched to status FAILING. > 10/29/2015 11:15:54 Grouped Aggregation -> (Map -> Stream Sink, Stream > Sink)(1/8) switched to FAILED > java.lang.Exception: Could not load the task's invokable class. > at > > org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:696) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:450) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.ClassCastException: class > org.apache.flink.streaming.runtime.tasks.OneInputStreamTask > at java.lang.Class.asSubclass(Class.java:3404) > at > > org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:693) > ... 2 more > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Could-not-load-the-task-s-invokable-class-tp3336.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
