flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sharma, Samiksha" <samiksha.sha...@here.com>
Subject Query regarding using storm topology in Flink
Date Wed, 09 Mar 2016 01:06:02 GMT

I am trying to run locally a storm topology in flink using the flink-storm library , but I
get the following error

Exception in thread "main" java.lang.NoClassDefFoundError: scala/concurrent/ExecutionContext

at org.apache.flink.storm.api.FlinkLocalCluster.<init>(FlinkLocalCluster.java:54)

at com.medio.services.avalanche.storm.common.BaseTopology.deploy(BaseTopology.java:116)

at com.medio.services.avalanche.realtime.eventcounter.EventCounterTopology.main(EventCounterTopology.java:18)

Caused by: java.lang.ClassNotFoundException: scala.concurrent.ExecutionContext

at java.net.URLClassLoader.findClass(URLClassLoader.java:381)

at java.lang.ClassLoader.loadClass(ClassLoader.java:424)

at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)

at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

... 3 more

It looks like the library is unable to find the ExecutionContext class and I am not sure how
to resolve this dependency.


Samiksha Sharma

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message