Skip to content

Getting ClosedChannelException:null from master #20

Description

@javadba

I have attempted to run simr --shell with 10 nodes. The 9 slave nodes were brought up and I can see they are still running by viewing the JobTracker UI. But the Master instance died. In the Mapper Log of the Master we see a few of the following exceptions:

2014-02-18 20:30:34,990 WARN akka.actor.ActorSystemImpl: RemoteClientWriteFailed@akka://SimrRelay@127.0.0.1:45121: MessageClass[scala.Tuple3] Error[java.nio.channels.ClosedChannelException:null
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.cleanUpWriteBuffer(AbstractNioWorker.java:703)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.writeFromUserCode(AbstractNioWorker.java:426)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:116)
at org.jboss.netty.channel.Channels.write(Channels.java:733)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:65)
at org.jboss.netty.channel.Channels.write(Channels.java:733)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:65)
at org.jboss.netty.handler.execution.ExecutionHandler.handleDownstream(ExecutionHandler.java:185)
at org.jboss.netty.channel.Channels.write(Channels.java:712)
at org.jboss.netty.channel.Channels.write(Channels.java:679)
at org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:246)
at akka.remote.netty.RemoteClient.send(Client.scala:76)
at akka.remote.netty.RemoteClient.send(Client.scala:63)
at akka.remote.netty.NettyRemoteTransport.send(NettyRemoteSupport.scala:154)
at akka.remote.RemoteActorRef.$bang(RemoteActorRefProvider.scala:247)
at org.apache.spark.simr.RelayServer$$anonfun$receive$1.apply(RelayServer.scala:180)
at org.apache.spark.simr.RelayServer$$anonfun$receive$1.apply(RelayServer.scala:151)
at akka.actor.Actor$class.apply(Actor.scala:318)
at org.apache.spark.simr.RelayServer.apply(RelayServer.scala:50)
at akka.actor.ActorCell.invoke(ActorCell.scala:626)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:197)
at akka.dispatch.Mailbox.run(Mailbox.scala:179)
at akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec(AbstractDispatcher.scala:516)
at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259)
at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:975)
at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479)
at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
]

Is this a configuration error or some other issue?

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions