You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tajo.apache.org by "hyoungjunkim (JIRA)" <ji...@apache.org> on 2013/11/07 04:31:17 UTC
[jira] [Created] (TAJO-302) TajoClient doesn't retry after cluster
restarted.
hyoungjunkim created TAJO-302:
---------------------------------
Summary: TajoClient doesn't retry after cluster restarted.
Key: TAJO-302
URL: https://issues.apache.org/jira/browse/TAJO-302
Project: Tajo
Issue Type: Bug
Components: client
Affects Versions: 0.2-incubating
Reporter: hyoungjunkim
After running several queries in tajo cli, restart tajo cluster.
Then run the query, the following error occurs.
But the query was submitted, and can't see the results because of an error.
SubmitQuery method of TajoClient implements with retry function, but getQueryStatus method has't retry function.
{code}
2013-11-07 12:07:36,062 ERROR rpc.RpcProtos (BlockingRpcClient.java:exceptionCaught(205)) - RPC Exception:null
2013-11-07 12:07:36,062 INFO rpc.RpcConnectionPool (RpcConnectionPool.java:closeConnection(78)) - CloseConnection [class org.apache.tajo.ipc.TajoMasterClientProtocol,xxx.xxx.xxx.xxx:26002,false]
2013-11-07 12:07:36,069 INFO rpc.NettyClientBase (NettyClientBase.java:close(90)) - Proxy is disconnected from xxx.xxx.xxx.xxx:26002
2013-11-07 12:07:38,214 ERROR rpc.RpcProtos (BlockingRpcClient.java:exceptionCaught(205)) - RPC Exception:null
2013-11-07 12:07:38,215 INFO rpc.RpcConnectionPool (RpcConnectionPool.java:closeConnection(78)) - CloseConnection [class org.apache.tajo.ipc.QueryMasterClientProtocol,xxx.xxx.xxx.xxx:28092,false]
2013-11-07 12:07:38,217 INFO rpc.NettyClientBase (NettyClientBase.java:close(90)) - Proxy is disconnected from xxx.xxx.xxx.xxx:28092
2013-11-07 12:07:38,217 INFO rpc.RpcConnectionPool (RpcConnectionPool.java:closeConnection(78)) - CloseConnection [class org.apache.tajo.ipc.TajoMasterClientProtocol,xxx.xxx.xxx.xxx:26002,false]
2013-11-07 12:07:38,219 INFO rpc.NettyClientBase (NettyClientBase.java:close(90)) - Proxy is disconnected from xxx.xxx.xxx.xxx:26002
com.google.protobuf.ServiceException: java.nio.channels.ClosedChannelException
at org.apache.tajo.client.TajoClient.getQueryStatus(TajoClient.java:209)
at org.apache.tajo.cli.TajoCli.getQueryResult(TajoCli.java:336)
at org.apache.tajo.cli.TajoCli.executeStatements(TajoCli.java:302)
at org.apache.tajo.cli.TajoCli.runShell(TajoCli.java:226)
at org.apache.tajo.cli.TajoCli.main(TajoCli.java:706)
Caused by: com.google.protobuf.ServiceException: java.nio.channels.ClosedChannelException
at org.apache.tajo.client.TajoClient.getQueryStatus(TajoClient.java:201)
... 4 more
Caused by: com.google.protobuf.ServiceException: java.nio.channels.ClosedChannelException
at org.apache.tajo.rpc.BlockingRpcClient$ProxyRpcChannel.callBlockingMethod(BlockingRpcClient.java:130)
at org.apache.tajo.ipc.QueryMasterClientProtocol$QueryMasterClientProtocolService$BlockingStub.getQueryStatus(QueryMasterClientProtocol.java:405)
at org.apache.tajo.client.TajoClient.getQueryStatus(TajoClient.java:195)
... 4 more
Caused by: java.nio.channels.ClosedChannelException
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.cleanUpWriteBuffer(AbstractNioWorker.java:434)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.writeFromUserCode(AbstractNioWorker.java:129)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:84)
at org.jboss.netty.channel.Channels.write(Channels.java:725)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.doEncode(OneToOneEncoder.java:71)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:59)
at org.jboss.netty.channel.Channels.write(Channels.java:725)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.doEncode(OneToOneEncoder.java:71)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:59)
at org.jboss.netty.channel.Channels.write(Channels.java:704)
at org.jboss.netty.channel.Channels.write(Channels.java:671)
at org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:248)
at org.apache.tajo.rpc.BlockingRpcClient$ProxyRpcChannel.callBlockingMethod(BlockingRpcClient.java:123)
... 6 more
java.nio.channels.ClosedChannelException
{code}
--
This message was sent by Atlassian JIRA
(v6.1#6144)