Hi! This looks like a mismatch between the Scala dependency in Flink and Scala in your Eclipse. Make sure you use the same for both. By default, Flink reference Scala 2.10
If your IDE is set up for Scala 2.11, set the Scala version variable in the Flink root pom.xml also to 2.11 Greetings, Stephan On Fri, Jan 8, 2016 at 12:06 PM, Vasudevan, Ramkrishna S < ramkrishna.s.vasude...@intel.com> wrote: > I have been trying to install, learn and understand Flink. I am using > Scala- EclipseIDE as my IDE. > > I have downloaded the flink source coded, compiled and created the project. > > My work laptop is Windows based and I don't have eclipse based workstation > but I do have linux boxes for running and testing things. > > Some of the examples given in Flink source code do run directly from > Eclipse but when I try to run the Wordcount example from Eclipse I get this > error > > Exception in thread "main" java.lang.NoSuchMethodError: > scala.collection.immutable.HashSet$.empty()Lscala/collection/immutable/HashSet; > at akka.actor.ActorCell$.<init>(ActorCell.scala:336) > at akka.actor.ActorCell$.<clinit>(ActorCell.scala) > at akka.actor.RootActorPath.$div(ActorPath.scala:159) > at akka.actor.LocalActorRefProvider.<init>(ActorRefProvider.scala:464) > at akka.actor.LocalActorRefProvider.<init>(ActorRefProvider.scala:452) > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native > Method) > at sun.reflect.NativeConstructorAccessorImpl.newInstance(Unknown > Source) > at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown > Source) > at java.lang.reflect.Constructor.newInstance(Unknown Source) > at > akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78) > at scala.util.Try$.apply(Try.scala:191) > at > akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:73) > at > akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3.apply(DynamicAccess.scala:84) > at > akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3.apply(DynamicAccess.scala:84) > at scala.util.Success.flatMap(Try.scala:230) > at > akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84) > at akka.actor.ActorSystemImpl.liftedTree1$1(ActorSystem.scala:585) > at akka.actor.ActorSystemImpl.<init>(ActorSystem.scala:578) > at akka.actor.ActorSystem$.apply(ActorSystem.scala:142) > at akka.actor.ActorSystem$.apply(ActorSystem.scala:119) > at akka.actor.ActorSystem$.create(ActorSystem.scala:67) > at > org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:84) > at > org.apache.flink.runtime.minicluster.FlinkMiniCluster.startJobManagerActorSystem(FlinkMiniCluster.scala:196) > at > org.apache.flink.runtime.minicluster.FlinkMiniCluster.singleActorSystem$lzycompute$1(FlinkMiniCluster.scala:225) > at org.apache.flink.runtime.minicluster.FlinkMiniCluster.org > $apache$flink$runtime$minicluster$FlinkMiniCluster$$singleActorSystem$1(FlinkMiniCluster.scala:225) > at > org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonfun$1.apply(FlinkMiniCluster.scala:230) > at > org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonfun$1.apply(FlinkMiniCluster.scala:228) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) > at scala.collection.immutable.Range.foreach(Range.scala:166) > at > scala.collection.TraversableLike$class.map(TraversableLike.scala:245) > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > at > org.apache.flink.runtime.minicluster.FlinkMiniCluster.start(FlinkMiniCluster.scala:228) > at > org.apache.flink.runtime.minicluster.FlinkMiniCluster.start(FlinkMiniCluster.scala:219) > at > org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:104) > at > org.apache.flink.streaming.examples.wordcount.WordCount.main(WordCount.java:80) > > I know this is a naïve question but I would like to get some help in order > to over come this issue. I tried various options like setting scala-2.10 as > the compiler for the project (then it shows completely different error) and > many of the projects don't even compile. But with 2.11 version I get the > above stack trace. Any help here is welcome. > > Regards > Ram >
