flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Query regarding using storm topology in Flink
Date Fri, 11 Mar 2016 21:34:19 GMT
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 <vitorsv.vieira@gmail.com>
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 <samiksha.sharma@here.com>:
>
> > 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
> >
>

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