You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@tajo.apache.org by "Jaehwa Jung (JIRA)" <ji...@apache.org> on 2014/07/21 03:30:38 UTC
[jira] [Resolved] (TAJO-942) NettyClientBase throws
RejectedExecutionException occasionally.
[ https://issues.apache.org/jira/browse/TAJO-942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jaehwa Jung resolved TAJO-942.
------------------------------
Resolution: Won't Fix
> NettyClientBase throws RejectedExecutionException occasionally.
> ---------------------------------------------------------------
>
> Key: TAJO-942
> URL: https://issues.apache.org/jira/browse/TAJO-942
> Project: Tajo
> Issue Type: Bug
> Components: rpc
> 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)