Hi, I’m trying to write a simple test project using Flink streaming and sbt. The project is in scala and it’s basically the set version of the maven archetype. I’m using the latest Flink 0.10-SNAPSHOT, building it for scala 2.11. I’ve written a simple test that starts a local environment, creates a stream from a collection and applies a map transformation. When running the test from sbt I get a ClassNotFoundException. When running the test from Intellij everything is fine. Could anyone please help with this? Following is the stack trace of the error.
Thanks, Giancarlo org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:414) at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) at org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36) at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) at org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33) at org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28) at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) at org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28) at akka.actor.Actor$class.aroundReceive(Actor.scala:465) at org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:104) ... Cause: java.lang.Exception: Could not load the task's invokable class. at org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:726) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:471) at java.lang.Thread.run(Thread.java:745) ... Cause: java.lang.ClassNotFoundException: org.apache.flink.streaming.runtime.tasks.OneInputStreamTask at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:348) at org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:722) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:471) at java.lang.Thread.run(Thread.java:745)
