[jira] [Created] (TAJO-942) NettyClientBase throws RejectedExecutionException occasionally.

["Jaehwa Jung (JIRA)" <ji...@apache.org>]

Jaehwa Jung created TAJO-942:
--------------------------------

             Summary: NettyClientBase throws RejectedExecutionException occasionally.
                 Key: TAJO-942
                 URL: https://issues.apache.org/jira/browse/TAJO-942
             Project: Tajo
          Issue Type: Bug
            Reporter: Jaehwa Jung
            Assignee: Jaehwa Jung


NettyClientBase throws RejectedExecutionException occasionally.

For example, add following simple codes to unit test cases.
{code:xml}
  @Test
  public final void testShutdownCluster() throws Exception {
    TajoTestingCluster activeMaster = new TajoTestingCluster();
    activeMaster.startMiniCluster(1);
    activeMaster.shutdownMiniCluster();
  }
{code}

If you added above codes,  run 'mvn clean install', and then you can find infinite loop as follows:

{code:xml}
2014-07-15 10:36:12,217 ERROR: org.apache.tajo.rpc.AsyncRpcClient (exceptionCaught(235)) - RPC Exception:java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
2014-07-15 10:36:12,218 ERROR: org.apache.tajo.worker.WorkerHeartbeatService (run(241)) - java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
	at org.apache.tajo.rpc.NettyClientBase.connect(NettyClientBase.java:93)
	at org.apache.tajo.rpc.RpcConnectionPool.getConnection(RpcConnectionPool.java:89)
	at org.apache.tajo.worker.WorkerHeartbeatService$WorkerHeartbeatThread.run(WorkerHeartbeatService.java:220)
Caused by: java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.registerTask(AbstractNioSelector.java:115)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.register(AbstractNioSelector.java:100)
	at org.jboss.netty.channel.socket.nio.NioClientBoss.register(NioClientBoss.java:42)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:121)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70)
	at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
	at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
	at org.jboss.netty.channel.Channels.connect(Channels.java:634)
	at org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
	at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
	at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
	at org.apache.tajo.rpc.NettyClientBase.connect(NettyClientBase.java:76)
{code}




--
This message was sent by Atlassian JIRA
(v6.2#6252)