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)
