drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rahul Challapalli (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (DRILL-3060) Random RpcException: Data not accepted downstream
Date Fri, 15 May 2015 02:01:05 GMT

     [ https://issues.apache.org/jira/browse/DRILL-3060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Rahul Challapalli updated DRILL-3060:
-------------------------------------
    Attachment: drillbit.log

Attached the complete log file which has this error. Steps followed

1. Submitted Tpch 12 query over SF100
2. Wait till the headers return and then kill the sqlline session (Not cancelling the query)
3. Now from the web UI cancelled the query

> Random RpcException: Data not accepted downstream
> -------------------------------------------------
>
>                 Key: DRILL-3060
>                 URL: https://issues.apache.org/jira/browse/DRILL-3060
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Execution - RPC
>            Reporter: Rahul Challapalli
>            Assignee: Deneche A. Hakim
>             Fix For: 1.0.0
>
>         Attachments: drillbit.log
>
>
> git.commit.id.abbrev=d10769f
> The error could be because of a race condition when running concurrent tests, but it
surfaced when running the below query which runs on tpch 0.01 GB
> {code}
> select
>   o_year,
>   sum(case
>     when nation = 'EGYPT' then volume
>     else 0
>   end) / sum(volume) as mkt_share
> from
>   (
>     select
>       extract(year from o.o_orderdate) as o_year,
>       l.l_extendedprice * (1 - l.l_discount) as volume,
>       n2.n_name as nation
>     from
>       part p,
>       supplier s,
>       lineitem l,
>       orders o,
>       customer c,
>       nation n1,
>       nation n2,
>       region r
>     where
>       p.p_partkey = l.l_partkey
>       and s.s_suppkey = l.l_suppkey
>       and l.l_orderkey = o.o_orderkey
>       and o.o_custkey = c.c_custkey
>       and c.c_nationkey = n1.n_nationkey
>       and n1.n_regionkey = r.r_regionkey
>       and r.r_name = 'MIDDLE EAST'
>       and s.s_nationkey = n2.n_nationkey
>       and o.o_orderdate between date '1995-01-01' and date '1996-12-31'
>       and p.p_type = 'PROMO BRUSHED COPPER'
>   ) as all_nations
> group by
>   o_year
> order by
>   o_year;
> {code}
> Error :
> {code}
> Failed with exception
> java.sql.SQLException: SYSTEM ERROR: org.apache.drill.exec.rpc.RpcException: Data not
accepted downstream.
> Fragment 6:0
> [Error Id: 9020d566-312e-4c1a-9360-cd5e7d1bc0ed on atsqa6c82.qa.lab:31010]
> 	at org.apache.drill.jdbc.DrillCursor.next(DrillCursor.java:161)
> 	at org.apache.drill.jdbc.impl.DrillResultSetImpl.execute(DrillResultSetImpl.java:167)
> 	at org.apache.drill.jdbc.impl.DrillResultSetImpl.execute(DrillResultSetImpl.java:56)
> 	at net.hydromatic.avatica.AvaticaConnection.executeQueryInternal(AvaticaConnection.java:404)
> 	at net.hydromatic.avatica.AvaticaStatement.executeQueryInternal(AvaticaStatement.java:351)
> 	at net.hydromatic.avatica.AvaticaStatement.executeQuery(AvaticaStatement.java:78)
> 	at org.apache.drill.jdbc.impl.DrillStatementImpl.executeQuery(DrillStatementImpl.java:89)
> 	at org.apache.drill.test.framework.DrillTestJdbc.executeQuery(DrillTestJdbc.java:139)
> 	at org.apache.drill.test.framework.DrillTestJdbc.run(DrillTestJdbc.java:80)
> 	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:744)
> Caused by: org.apache.drill.common.exceptions.UserRemoteException: SYSTEM ERROR: org.apache.drill.exec.rpc.RpcException:
Data not accepted downstream.
> Fragment 6:0
> [Error Id: 9020d566-312e-4c1a-9360-cd5e7d1bc0ed on atsqa6c82.qa.lab:31010]
> 	at org.apache.drill.exec.rpc.user.QueryResultHandler.resultArrived(QueryResultHandler.java:118)
> 	at org.apache.drill.exec.rpc.user.UserClient.handleReponse(UserClient.java:111)
> 	at org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:47)
> 	at org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:32)
> 	at org.apache.drill.exec.rpc.RpcBus.handle(RpcBus.java:59)
> 	at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:214)
> 	at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:188)
> 	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> 	at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
> 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> 	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> 	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> 	at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
> 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> 	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> 	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
> 	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
> 	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> 	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> 	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> 	at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> 	... 1 more
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message