flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vasudevan, Ramkrishna S" <ramkrishna.s.vasude...@intel.com>
Subject Naive question
Date Fri, 08 Jan 2016 11:06:16 GMT
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

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