(DEPRECATED) Apache Flink User Mailing List archive.

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

Posted by Stephan Ewen on Nov 02, 2015; 7:16pm
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Could-not-load-the-task-s-invokable-class-tp3336p3338.html

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 <[hidden email]> 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.