flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Flink and sbt
Date Wed, 09 Sep 2015 12:48:31 GMT
Damn. I saw this discussion too late. I think the "fork = true" is
documented here:
https://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/scala_api_quickstart.html#alternative-build-tools-sbt

On Wed, Sep 9, 2015 at 2:46 PM, Giancarlo Pagano <Giancarlo@beamly.com>
wrote:

> I’ve actually found the problem in the meanwhile, build.sbt was missing '
> fork := true'.
> Sorry about that.
>
> Thanks,
> Giancarlo
>
>
>
>
> On 9 Sep 2015, at 11:43, Anwar Rizal <anrizal05@gmail.com> wrote:
>
> Can you share the build.sbt or the scala , and maybe a small portion of
> the code ?
>
>
> On Wed, Sep 9, 2015 at 12:27 PM, Giancarlo Pagano <Giancarlo@beamly.com>
> wrote:
>
>> 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)
>
>
>
>

Mime
View raw message