Query regarding using storm topology in Flink

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Query regarding using storm topology in Flink

Sharma, Samiksha
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
Reply | Threaded
Open this post in threaded view
|

Re: Query regarding using storm topology in Flink

Vitor Vieira
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
>
Reply | Threaded
Open this post in threaded view
|

Re: Query regarding using storm topology in Flink

Robert Metzger
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
> >
>