Flink Streaming java.lang.Exception：无法加载任务的可调用类答案

【问题标题】：Flink Streaming java.lang.Exception: Could not load the task's invokable classFlink Streaming java.lang.Exception：无法加载任务的可调用类
【发布时间】：2015-10-29 15:40:35
【问题描述】：

我正在尝试在本地运行基本的 Flink 流式传输作业（在 java 中）。当我使用 eclipse 运行我的应用程序时，它就像一个魅力。但是当我使用 Flink 命令行界面运行时，我得到了以下异常

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(Tas k.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(Tas    k.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(Tas    k.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(Tas    k.java:693)
... 2 more

我正在运行 Flink-Kafka 集成示例： data-artisans

【问题讨论】：

您在命令行中使用哪个版本的java JDK 进行编译，您在eclipse 中使用哪个版本进行编译？
这两种情况我都使用 Java 1.8。
你能升级到60吗？
您好 Eric，我已尝试将我的 Java 更新到 1.8.0_65，我认为这是最新版本，但问题仍然存在。
您使用什么命令行命令来运行应用程序？

标签： java streaming apache-flink flink-streaming

【解决方案1】：

问题已在 Flink 邮件列表中得到解答：http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Could-not-load-the-task-s-invokable-class-td3336.html

问题是 Flink 程序的 jar 是使用 Eclipse 构建的。用户能够使用 Maven 构建一个工作 jar。

【讨论】：