Re: Query regarding using storm topology in Flink

2016-03-11 Thread 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 wrote: > Hi Samiksha > > Could you post here what dependencies are you using. It looks like you > could be using outdated dependencies, or making unnecessary ref

Re: Query regarding using storm topology in Flink

2016-03-08 Thread 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 2016-03-08 22:06 GMT-03:00 Sharma, Samiksha :

Query regarding using storm topology in Flink

2016-03-08 Thread 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.(FlinkLocalCluster.java:54) at