rjagerman / glint

Glint: High performance scala parameter server
MIT License
168 stars 62 forks source link

Akka Actor Error when initializing Glint Client #68

Open mnoumanshahzad opened 7 years ago

mnoumanshahzad commented 7 years ago

I am trying this implementation of Glint with Apache Flink. I am rather new to Akka and can not figure out the following error message:

java.lang.NoSuchMethodError: akka.pattern.AskableActorRef$.$qmark$default$3$extension(Lakka/actor/ActorRef;Ljava/lang/Object;)Lakka/actor/ActorRef; at glint.Client.<init>(Client.scala:40) at glint.Client$$anonfun$start$1.apply(Client.scala:302) at glint.Client$$anonfun$start$1.apply(Client.scala:300) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:253) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:251) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) at scala.concurrent.impl.ExecutionContextImpl$AdaptedForkJoinTask.exec(ExecutionContextImpl.scala:121) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

This message appears simply when I try to create a client ( i.e val gc = Client() ) Is it possible that this message is caused because Apache Flink uses a different version of Akka that Glint and somehow Glint is using the Akka version that Apache Flink has imported? If so, how can I ensure that the right version of Akka is called for Glint and Apache Flink respectively?

Thanks

MLnick commented 7 years ago

Likely a version conflict - either scala version or akka. If akka then unless Flink has a way to manage classpath loading then you can try shading your akka dependency On Sun, 28 May 2017 at 15:05, Muhammad Nouman Shahzad < notifications@github.com> wrote:

I am trying this implementation of Glint with Apache Flink. I am rather new to Akka and can not figure out the following error message:

java.lang.NoSuchMethodError: akka.pattern.AskableActorRef$.$qmark$default$3$extension(Lakka/actor/ActorRef;Ljava/lang/Object;)Lakka/actor/ActorRef; at glint.Client.(Client.scala:40) at glint.Client$$anonfun$start$1.apply(Client.scala:302) at glint.Client$$anonfun$start$1.apply(Client.scala:300) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:253) at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:251) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) at scala.concurrent.impl.ExecutionContextImpl$AdaptedForkJoinTask.exec(ExecutionContextImpl.scala:121) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

This message appears simply when I try to create a client ( i.e val gc = Client() ) Is it possible that this message is caused because Apache Flink uses a different version of Akka that Glint and somehow Glint is using the Akka version that Apache Flink has imported? If so, how can I ensure that the right version of Akka is called for Glint and Apache Flink respectively?

Thanks

— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub https://github.com/rjagerman/glint/issues/68, or mute the thread https://github.com/notifications/unsubscribe-auth/AA_SB6qNPUiMcf8LtfF0znNv5EtjLisOks5r-XEygaJpZM4NopFl .

mnoumanshahzad commented 7 years ago

Thanks alot for a speedy reply. Could you also point out the preferred versions of Scala, SBT and Akka for Glint? I figured out the following from the build.sbt for Glint Scala Version = 2.10.6 or 2.11.8 SBT Version = I am using 0.13.15 and it works fine. Akka Version = 2.3.15 (for Scala 2.10) and 2.4.12 (for Scala 2.4.12)