You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@zeppelin.apache.org by 江之源 <ji...@liulishuo.com> on 2015/07/13 12:20:46 UTC

The Interpreter null not found in zeppelin, the remote didn't start successfully.

I install zeppelin in both local and cluster model.The local model works
well, but the cluster model don't work well. i run the tutorial example and
it responds the error:
Interpreter null not found.

my install config is spark1.3 and Hadoop 2.0.0-cdh4.5.0.
it shows the remote didn't start successfully.

and the interpreter-spark-log writes:

ERROR [2015-07-13 16:56:11,020]
({sparkDriver-akka.actor.default-dispatcher-3}
Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
[sparkDriver-akka.remote.default-remote-dispatcher-5] shutting down
ActorSystem [sparkDriver]

java.lang.VerifyError: (class:
org/jboss/netty/channel/socket/nio/NioWorkerPool, method: createWorker
signature:
(Ljava/util/concurrent/Executor;)Lorg/jboss/netty/channel/socket/nio/AbstractNioWorker;)
Wrong return type in function

at
akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:283)

        at
akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:240)

        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method)

        at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)

        at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)

        at java.lang.reflect.Constructor.newInstance(Constructor.java:526)

        at
akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78)

        at scala.util.Try$.apply(Try.scala:161)

        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:200)

        at
akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84)

        at akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:692)

        at akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:684)

        at
scala.collection.TraversableLike$WithFilter$$anonfun$map$2.apply(TraversableLike.scala:722)

        at scala.collection.Iterator$class.foreach(Iterator.scala:727)

        at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)

        at
scala.collection.IterableLike$class.foreach(IterableLike.scala:72)

        at scala.collection.AbstractIterable.foreach(Iterable.scala:54)

        at
scala.collection.TraversableLike$WithFilter.map(TraversableLike.scala:721)

        at
akka.remote.EndpointManager.akka$remote$EndpointManager$$listens(Remoting.scala:684)

        at
akka.remote.EndpointManager$$anonfun$receive$2.applyOrElse(Remoting.scala:492)

        at akka.actor.Actor$class.aroundReceive(Actor.scala:465)

        at akka.remote.EndpointManager.aroundReceive(Remoting.scala:395)

        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)

        at akka.actor.ActorCell.invoke(ActorCell.scala:487)

        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)

        at akka.dispatch.Mailbox.run(Mailbox.scala:220)

        at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)

        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)

it shows the remote didn't start successfully.

please help me.thanks so much

Re: The Interpreter null not found in zeppelin, the remote didn't start successfully.

Posted by 江之源 <ji...@liulishuo.com>.
moon:
hi ! sorry to bother you again. I spend all day trying to make a solution
about the error:

ERROR [2015-07-14 19:17:13,391]
({sparkDriver-akka.actor.default-dispatcher-4}
Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
[sparkDriver-akka.remote.default-remote-dispatcher-6] shutting down
ActorSystem [sparkDriver]

java.lang.VerifyError: (class:
org/jboss/netty/channel/socket/nio/NioWorkerPool,
method: createWorker signature: (Ljava/util/concurrent/Executor;)Lorg/jboss/
netty/channel/socket/nio/AbstractNioWorker;) Wrong return type in function

        at akka.remote.transport.netty
.NettyTransport.<init>(NettyTransport.scala:283)

        at akka.remote.transport.netty
.NettyTransport.<init>(NettyTransport.scala:240)

        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method)

        at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)

        at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)

        at java.lang.reflect.Constructor.newInstance(Constructor.java:526)

        at
akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78)

        at scala.util.Try$.apply(Try.scala:161)

        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:200)

        at
akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84)

        at akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:692)

        at akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:684)

        at
scala.collection.TraversableLike$WithFilter$$anonfun$map$2.apply(TraversableLike.scala:722)

        at scala.collection.Iterator$class.foreach(Iterator.scala:727)

        at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)

        at
scala.collection.IterableLike$class.foreach(IterableLike.scala:72)

        at scala.collection.AbstractIterable.foreach(Iterable.scala:54)

        at
scala.collection.TraversableLike$WithFilter.map(TraversableLike.scala:721)

        at
akka.remote.EndpointManager.akka$remote$EndpointManager$$listens(Remoting.scala:684)

        at
akka.remote.EndpointManager$$anonfun$receive$2.applyOrElse(Remoting.scala:492)

        at akka.actor.Actor$class.aroundReceive(Actor.scala:465)

        at akka.remote.EndpointManager.aroundReceive(Remoting.scala:395)

        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)

        at akka.actor.ActorCell.invoke(ActorCell.scala:487)

        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)

        at akka.dispatch.Mailbox.run(Mailbox.scala:220)

        at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)

        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)
and i modify the version netty version in the pom.xml, delete the another
version, now the netty in pom.xml is


  <groupId>io.netty</groupId>

  <artifactId>netty</artifactId>

  <packaging>bundle</packaging>

  <version>3.10.4.Final</version>

the question is still it.... how can i fix it.much thanks~

On Tue, Jul 14, 2015 at 10:27 AM, 江之源 <ji...@liulishuo.com> wrote:

> Moon:
> hi~
> I check the setting gear button, all the buttons appear blue. The
> interpret null not found error disappeared, however it turns to the second
> error above.You said i had multiple versions of the netty in my chasspath,
> and i also haven't set classpath.I just can find the netty in my
> incubator-zeppelin-master/spark/pom.xml. Can you help me more detail, if
> you wanna any info i can paste to you. I forget to say my cluster is
> standalone, neither Yarn nor mesos. i don't know is this a problem.
> Much thanks to u
> jzy
>
> On Tue, Jul 14, 2015 at 1:17 AM, moon soo Lee <mo...@apache.org> wrote:
>
>> Hi,
>>
>> Interpreter null not found.
>>
>> This error is happening when there're no binded interpreter to your
>> notebook. You can bind interpreters with small gear button on top right
>> corner of your notebook.
>>
>> ERROR [2015-07-13 16:56:11,020]
>> ({sparkDriver-akka.actor.default-dispatcher-3}
>> Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
>> [sparkDriver-akka.remote.default-remote-dispatcher-5] shutting down
>> ActorSystem [sparkDriver]
>>
>> java.lang.VerifyError: (class:
>> org/jboss/netty/channel/socket/nio/NioWorkerPool, method: createWorker
>> signature:
>> (Ljava/util/concurrent/Executor;)Lorg/jboss/netty/channel/socket/nio/AbstractNioWorker;)
>> Wrong return type in function
>>
>> This error came from different reason. The problem can happen when you
>> have multiple version of the same library (netty) in your classpath.
>>
>> Hope this helps.
>>
>> Best,
>> moon
>>
>> On Mon, Jul 13, 2015 at 3:21 AM 江之源 <ji...@liulishuo.com> wrote:
>>
>>> I install zeppelin in both local and cluster model.The local model works
>>> well, but the cluster model don't work well. i run the tutorial example and
>>> it responds the error:
>>> Interpreter null not found.
>>>
>>> my install config is spark1.3 and Hadoop 2.0.0-cdh4.5.0.
>>> it shows the remote didn't start successfully.
>>>
>>> and the interpreter-spark-log writes:
>>>
>>> ERROR [2015-07-13 16:56:11,020]
>>> ({sparkDriver-akka.actor.default-dispatcher-3}
>>> Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
>>> [sparkDriver-akka.remote.default-remote-dispatcher-5] shutting down
>>> ActorSystem [sparkDriver]
>>>
>>> java.lang.VerifyError: (class:
>>> org/jboss/netty/channel/socket/nio/NioWorkerPool, method: createWorker
>>> signature:
>>> (Ljava/util/concurrent/Executor;)Lorg/jboss/netty/channel/socket/nio/AbstractNioWorker;)
>>> Wrong return type in function
>>>
>>> at
>>> akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:283)
>>>
>>>         at
>>> akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:240)
>>>
>>>         at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
>>> Method)
>>>
>>>         at
>>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
>>>
>>>         at
>>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
>>>
>>>         at
>>> java.lang.reflect.Constructor.newInstance(Constructor.java:526)
>>>
>>>         at
>>> akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78)
>>>
>>>         at scala.util.Try$.apply(Try.scala:161)
>>>
>>>         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:200)
>>>
>>>         at
>>> akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84)
>>>
>>>         at
>>> akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:692)
>>>
>>>         at
>>> akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:684)
>>>
>>>         at
>>> scala.collection.TraversableLike$WithFilter$$anonfun$map$2.apply(TraversableLike.scala:722)
>>>
>>>         at scala.collection.Iterator$class.foreach(Iterator.scala:727)
>>>
>>>         at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
>>>
>>>         at
>>> scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
>>>
>>>         at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
>>>
>>>         at
>>> scala.collection.TraversableLike$WithFilter.map(TraversableLike.scala:721)
>>>
>>>         at
>>> akka.remote.EndpointManager.akka$remote$EndpointManager$$listens(Remoting.scala:684)
>>>
>>>         at
>>> akka.remote.EndpointManager$$anonfun$receive$2.applyOrElse(Remoting.scala:492)
>>>
>>>         at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
>>>
>>>         at akka.remote.EndpointManager.aroundReceive(Remoting.scala:395)
>>>
>>>         at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
>>>
>>>         at akka.actor.ActorCell.invoke(ActorCell.scala:487)
>>>
>>>         at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)
>>>
>>>         at akka.dispatch.Mailbox.run(Mailbox.scala:220)
>>>
>>>         at
>>> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
>>>
>>>         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)
>>>
>>> it shows the remote didn't start successfully.
>>>
>>> please help me.thanks so much
>>>
>>
>

Re: The Interpreter null not found in zeppelin, the remote didn't start successfully.

Posted by 江之源 <ji...@liulishuo.com>.
Moon:
hi~
I check the setting gear button, all the buttons appear blue. The interpret
null not found error disappeared, however it turns to the second error
above.You said i had multiple versions of the netty in my chasspath, and i
also haven't set classpath.I just can find the netty in my
incubator-zeppelin-master/spark/pom.xml. Can you help me more detail, if
you wanna any info i can paste to you. I forget to say my cluster is
standalone, neither Yarn nor mesos. i don't know is this a problem.
Much thanks to u
jzy

On Tue, Jul 14, 2015 at 1:17 AM, moon soo Lee <mo...@apache.org> wrote:

> Hi,
>
> Interpreter null not found.
>
> This error is happening when there're no binded interpreter to your
> notebook. You can bind interpreters with small gear button on top right
> corner of your notebook.
>
> ERROR [2015-07-13 16:56:11,020]
> ({sparkDriver-akka.actor.default-dispatcher-3}
> Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
> [sparkDriver-akka.remote.default-remote-dispatcher-5] shutting down
> ActorSystem [sparkDriver]
>
> java.lang.VerifyError: (class:
> org/jboss/netty/channel/socket/nio/NioWorkerPool, method: createWorker
> signature:
> (Ljava/util/concurrent/Executor;)Lorg/jboss/netty/channel/socket/nio/AbstractNioWorker;)
> Wrong return type in function
>
> This error came from different reason. The problem can happen when you
> have multiple version of the same library (netty) in your classpath.
>
> Hope this helps.
>
> Best,
> moon
>
> On Mon, Jul 13, 2015 at 3:21 AM 江之源 <ji...@liulishuo.com> wrote:
>
>> I install zeppelin in both local and cluster model.The local model works
>> well, but the cluster model don't work well. i run the tutorial example and
>> it responds the error:
>> Interpreter null not found.
>>
>> my install config is spark1.3 and Hadoop 2.0.0-cdh4.5.0.
>> it shows the remote didn't start successfully.
>>
>> and the interpreter-spark-log writes:
>>
>> ERROR [2015-07-13 16:56:11,020]
>> ({sparkDriver-akka.actor.default-dispatcher-3}
>> Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
>> [sparkDriver-akka.remote.default-remote-dispatcher-5] shutting down
>> ActorSystem [sparkDriver]
>>
>> java.lang.VerifyError: (class:
>> org/jboss/netty/channel/socket/nio/NioWorkerPool, method: createWorker
>> signature:
>> (Ljava/util/concurrent/Executor;)Lorg/jboss/netty/channel/socket/nio/AbstractNioWorker;)
>> Wrong return type in function
>>
>> at
>> akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:283)
>>
>>         at
>> akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:240)
>>
>>         at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
>> Method)
>>
>>         at
>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
>>
>>         at
>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
>>
>>         at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
>>
>>         at
>> akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78)
>>
>>         at scala.util.Try$.apply(Try.scala:161)
>>
>>         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:200)
>>
>>         at
>> akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84)
>>
>>         at
>> akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:692)
>>
>>         at
>> akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:684)
>>
>>         at
>> scala.collection.TraversableLike$WithFilter$$anonfun$map$2.apply(TraversableLike.scala:722)
>>
>>         at scala.collection.Iterator$class.foreach(Iterator.scala:727)
>>
>>         at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
>>
>>         at
>> scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
>>
>>         at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
>>
>>         at
>> scala.collection.TraversableLike$WithFilter.map(TraversableLike.scala:721)
>>
>>         at
>> akka.remote.EndpointManager.akka$remote$EndpointManager$$listens(Remoting.scala:684)
>>
>>         at
>> akka.remote.EndpointManager$$anonfun$receive$2.applyOrElse(Remoting.scala:492)
>>
>>         at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
>>
>>         at akka.remote.EndpointManager.aroundReceive(Remoting.scala:395)
>>
>>         at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
>>
>>         at akka.actor.ActorCell.invoke(ActorCell.scala:487)
>>
>>         at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)
>>
>>         at akka.dispatch.Mailbox.run(Mailbox.scala:220)
>>
>>         at
>> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
>>
>>         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)
>>
>> it shows the remote didn't start successfully.
>>
>> please help me.thanks so much
>>
>

Re: The Interpreter null not found in zeppelin, the remote didn't start successfully.

Posted by moon soo Lee <mo...@apache.org>.
Hi,

Interpreter null not found.

This error is happening when there're no binded interpreter to your
notebook. You can bind interpreters with small gear button on top right
corner of your notebook.

ERROR [2015-07-13 16:56:11,020]
({sparkDriver-akka.actor.default-dispatcher-3}
Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
[sparkDriver-akka.remote.default-remote-dispatcher-5] shutting down
ActorSystem [sparkDriver]

java.lang.VerifyError: (class:
org/jboss/netty/channel/socket/nio/NioWorkerPool, method: createWorker
signature:
(Ljava/util/concurrent/Executor;)Lorg/jboss/netty/channel/socket/nio/AbstractNioWorker;)
Wrong return type in function

This error came from different reason. The problem can happen when you have
multiple version of the same library (netty) in your classpath.

Hope this helps.

Best,
moon

On Mon, Jul 13, 2015 at 3:21 AM 江之源 <ji...@liulishuo.com> wrote:

> I install zeppelin in both local and cluster model.The local model works
> well, but the cluster model don't work well. i run the tutorial example and
> it responds the error:
> Interpreter null not found.
>
> my install config is spark1.3 and Hadoop 2.0.0-cdh4.5.0.
> it shows the remote didn't start successfully.
>
> and the interpreter-spark-log writes:
>
> ERROR [2015-07-13 16:56:11,020]
> ({sparkDriver-akka.actor.default-dispatcher-3}
> Slf4jLogger.scala[apply$mcV$sp]:66) - Uncaught fatal error from thread
> [sparkDriver-akka.remote.default-remote-dispatcher-5] shutting down
> ActorSystem [sparkDriver]
>
> java.lang.VerifyError: (class:
> org/jboss/netty/channel/socket/nio/NioWorkerPool, method: createWorker
> signature:
> (Ljava/util/concurrent/Executor;)Lorg/jboss/netty/channel/socket/nio/AbstractNioWorker;)
> Wrong return type in function
>
> at
> akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:283)
>
>         at
> akka.remote.transport.netty.NettyTransport.<init>(NettyTransport.scala:240)
>
>         at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
> Method)
>
>         at
> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
>
>         at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
>
>         at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
>
>         at
> akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78)
>
>         at scala.util.Try$.apply(Try.scala:161)
>
>         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:200)
>
>         at
> akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84)
>
>         at akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:692)
>
>         at akka.remote.EndpointManager$$anonfun$9.apply(Remoting.scala:684)
>
>         at
> scala.collection.TraversableLike$WithFilter$$anonfun$map$2.apply(TraversableLike.scala:722)
>
>         at scala.collection.Iterator$class.foreach(Iterator.scala:727)
>
>         at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
>
>         at
> scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
>
>         at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
>
>         at
> scala.collection.TraversableLike$WithFilter.map(TraversableLike.scala:721)
>
>         at
> akka.remote.EndpointManager.akka$remote$EndpointManager$$listens(Remoting.scala:684)
>
>         at
> akka.remote.EndpointManager$$anonfun$receive$2.applyOrElse(Remoting.scala:492)
>
>         at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
>
>         at akka.remote.EndpointManager.aroundReceive(Remoting.scala:395)
>
>         at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
>
>         at akka.actor.ActorCell.invoke(ActorCell.scala:487)
>
>         at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)
>
>         at akka.dispatch.Mailbox.run(Mailbox.scala:220)
>
>         at
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
>
>         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)
>
> it shows the remote didn't start successfully.
>
> please help me.thanks so much
>