tajo-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "hyoungjunkim (JIRA)" <j...@apache.org>
Subject [jira] [Created] (TAJO-302) TajoClient doesn't retry after cluster restarted.
Date Thu, 07 Nov 2013 03:31:17 GMT
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)

Mime
View raw message