[DRILL-650] Left outer join sometimes fails sometimes with Failure while setting up Foreman error

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.4.0
• Component/s: Execution - Relational Operators
• Assignee: Aditya Kishore
• Reporter: Ramana Inukonda Nagaraj
• Created: 07/May/14 00:05
• Updated: 20/Jun/14 20:37
• Resolved: 20/Jun/14 20:28

Description

Have been seeing this sporadically. Does not happen on a clean drill install or on a recently restarted drillbit.

select c.C_custkey,c.C_NAME,o.O_ORDERKEY from customer c left outer join orders o on c.c_custkey = o.o_custkey
Query failed: org.apache.drill.exec.rpc.RpcException: Remote failure while running query.[error_id: "8136e657-1366-476e-ba67-0cfa2aeda169"
endpoint {
address: "drillats2.qa.lab"
user_port: 31010
control_port: 31011
java.sql.SQLException: exception while executing query
data_port: 31012
}
at net.hydromatic.avatica.Helper.createException(Helper.java:40)
at net.hydromatic.avatica.AvaticaConnection.executeQueryInternal(AvaticaConnection.java:406)
error_type: 0
at net.hydromatic.avatica.AvaticaStatement.executeQueryInternal(AvaticaStatement.java:350)
message: "Failure while setting up Foreman. < AssertionError"
]
at net.hydromatic.avatica.AvaticaStatement.executeQuery(AvaticaStatement.java:78)
at org.apache.drill.test.framework.GenericQueryDispatcher.dispatchQueryJDBC(GenericQueryDispatcher.java:88)
at org.apache.drill.test.framework.DrillTestBase$RunThread.run(DrillTestBase.java:269)
Caused by: java.sql.SQLException: Failure while trying to get next result batch.
at org.apache.drill.jdbc.DrillCursor.next(DrillCursor.java:101)
at org.apache.drill.jdbc.DrillResultSet.execute(DrillResultSet.java:89)
at org.apache.drill.jdbc.DrillResultSet.execute(DrillResultSet.java:43)
at net.hydromatic.avatica.AvaticaConnection.executeQueryInternal(AvaticaConnection.java:404)
... 4 more
Caused by: org.apache.drill.exec.rpc.RpcException: Remote failure while running query.[error_id: "8136e657-1366-476e-ba67-0cfa2aeda169"
endpoint {
address: "drillats2.qa.lab"
user_port: 31010
control_port: 31011
data_port: 31012
}
error_type: 0
message: "Failure while setting up Foreman. < AssertionError"
]
at org.apache.drill.exec.rpc.user.QueryResultHandler.batchArrived(QueryResultHandler.java:72)
at org.apache.drill.exec.rpc.user.UserClient.handleReponse(UserClient.java:80)
at org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:52)
at org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:34)
at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:154)
at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:139)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)
at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)
at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:173)
at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)
at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)
at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:100)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:465)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:359)
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101)
at java.lang.Thread.run(Thread.java:744)