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, 江之源 <jiangzhiy...@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 <m...@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 江之源 <jiangzhiy...@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
>>>
>>
>
