flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Could not load the task's invokable class.
Date Mon, 02 Nov 2015 19:28:28 GMT
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 <e106625@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.
>

Mime
View raw message