Hi, Because I’m not user of Eclipse so I’m not sure but think that IDE Setup documentation [1] on Flink homepage could help you.
[1] https://ci.apache.org/projects/flink/flink-docs-master/internals/ide_setup.html > On Jan 8, 2016, at 8:30 PM, Stephan Ewen <se...@apache.org> wrote: > > 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 >> Regards, Chiwan Park
