基本的な 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 で実行しています。