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

Reply via email to