Hi,
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. Thanks Samiksha Sharma |
Hi Samiksha
Could you post here what dependencies are you using. It looks like you could be using outdated dependencies, or making unnecessary references to an already imported dependency. Rgds, Vitor Vieira @notvitor <https://twitter.com/notvitor> 2016-03-08 22:06 GMT-03:00 Sharma, Samiksha <[hidden email]>: > Hi, > > 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. > > > Thanks > > Samiksha Sharma > |
I agree with Victor. Such errors are often caused by scala version mixups
(2.10 vs 2.11). On Wed, Mar 9, 2016 at 2:42 AM, Vitor Vieira <[hidden email]> wrote: > Hi Samiksha > > Could you post here what dependencies are you using. It looks like you > could be using outdated dependencies, or making unnecessary references to > an already imported dependency. > > Rgds, > > Vitor Vieira > @notvitor <https://twitter.com/notvitor> > > 2016-03-08 22:06 GMT-03:00 Sharma, Samiksha <[hidden email]>: > > > Hi, > > > > 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. > > > > > > Thanks > > > > Samiksha Sharma > > > |
Free forum by Nabble | Edit this page |