Github user jinossy commented on the pull request:
https://github.com/apache/tajo/pull/311#issuecomment-76659550
@ykrips
Could you fix following error ? I ran TPCH-Q3
* Error 1
```
2015-03-02 11:41:19,399 WARN org.apache.tajo.rpc.RpcConnectionPool: Try to
reconnect : server1/xxx.xxx.xxx.xxx:28091
2015-03-02 11:41:19,405 ERROR org.apache.tajo.rpc.AsyncRpcClient:
server2/xxx.xxx.xxx.xxx:28091,class
org.apache.tajo.ipc.TajoWorkerProtocol,java.nio.channels.ClosedCh
annelException
com.google.protobuf.ServiceException:
java.nio.channels.ClosedChannelException
at
org.apache.tajo.rpc.AsyncRpcClient$ProxyRpcChannel$1.operationComplete(AsyncRpcClient.java:147)
at
org.apache.tajo.rpc.AsyncRpcClient$ProxyRpcChannel$1.operationComplete(AsyncRpcClient.java:142)
at
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
at
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:567)
at
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:424)
at
io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetFailure(AbstractChannel.java:754)
at
io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:655)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1113)
at
io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:633)
at
io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:32)
at
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:908)
at
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:960)
at
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:893)
at
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:380)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357)
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.nio.channels.ClosedChannelException
2015-03-02 11:41:19,407 ERROR org.apache.tajo.master.ContainerProxy:
Connect error to server3/xxx.xxx.xxx.xxx:28091 caused by
io.netty.channel.ConnectTimeoutException: Connect error to
server3/xxx.xxx.xxx.xxx:28091 caused by
at
org.apache.tajo.rpc.NettyClientBase.handleConnectionInternally(NettyClientBase.java:93)
at
org.apache.tajo.rpc.NettyClientBase.connect(NettyClientBase.java:103)
at
org.apache.tajo.rpc.RpcConnectionPool.getConnection(RpcConnectionPool.java:96)
at
org.apache.tajo.master.TajoContainerProxy.assignExecutionBlock(TajoContainerProxy.java:105)
at
org.apache.tajo.master.TajoContainerProxy.launch(TajoContainerProxy.java:75)
at
org.apache.tajo.worker.TajoResourceAllocator$LaunchRunner.run(TajoResourceAllocator.java:210)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
```
* Error 2
```
2015-03-02 11:41:19,406 ERROR org.apache.tajo.rpc.AsyncRpcClient:
null,class
org.apache.tajo.ipc.TajoWorkerProtocol,java.lang.UnsupportedOperationException:
unsupported message type:
RpcProtos$RpcRequest (expected: ByteBuf, FileRegion)
com.google.protobuf.ServiceException:
java.lang.UnsupportedOperationException: unsupported message type:
RpcProtos$RpcRequest (expected: ByteBuf, FileRegion)
at
org.apache.tajo.rpc.AsyncRpcClient$ProxyRpcChannel$1.operationComplete(AsyncRpcClient.java:147)
at
org.apache.tajo.rpc.AsyncRpcClient$ProxyRpcChannel$1.operationComplete(AsyncRpcClient.java:142)
at
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
at
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:567)
at
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:424)
at
io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetFailure(AbstractChannel.java:754)
at
io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:669)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1113)
at
io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:633)
at
io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:32)
at
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:908)
at
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:960)
at
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:893)
at
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:380)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357)
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.UnsupportedOperationException: unsupported message
type: RpcProtos$RpcRequest (expected: ByteBuf, FileRegion)
at
io.netty.channel.nio.AbstractNioByteChannel.filterOutboundMessage(AbstractNioByteChannel.java:280)
at
io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:663)
... 10 more
```
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
