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 via email to