drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Krystal (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (DRILL-2117) tpcds impala q53 query randomly fails with memory leak
Date Thu, 29 Jan 2015 18:32:34 GMT

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

Krystal updated DRILL-2117:
---------------------------
    Attachment: drill2117.log

server log

> tpcds impala q53 query randomly fails with memory leak
> ------------------------------------------------------
>
>                 Key: DRILL-2117
>                 URL: https://issues.apache.org/jira/browse/DRILL-2117
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Execution - RPC
>    Affects Versions: 0.8.0
>            Reporter: Krystal
>            Assignee: Victoria Markman
>         Attachments: drill2117.log
>
>
> Commit  54b5f80
> The following tpcds impala sf1 q53 randomly fails:
> select
>   *
> from
>   (select
>     i.i_manufact_id as imid,
>     sum(ss.ss_sales_price) sum_sales
>     -- avg(sum(ss.ss_sales_price)) over (partition by i.i_manufact_id) avg_quarterly_sales
>   from
>     item as i,
>     store_sales as ss,
>     date_dim as d,
>     store as s
>   where
>     ss.ss_item_sk = i.i_item_sk
>     and ss.ss_sold_date_sk = d.d_date_sk
>     and ss.ss_store_sk = s.s_store_sk
>     and d.d_month_seq in (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212
+ 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11)
>     and ((i.i_category in ('Books', 'Children', 'Electronics')
>       and i.i_class in ('personal', 'portable', 'reference', 'self-help')
>       and i.i_brand in ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg
#9', 'scholaramalgamalg #9'))
>     or (i.i_category in ('Women', 'Music', 'Men')
>       and i.i_class in ('accessories', 'classical', 'fragrances', 'pants')
>       and i.i_brand in ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1',
'importoamalg #1')))
>     and ss.ss_sold_date_sk between 2451911 and 2452275 -- partition key filter
>   group by
>     i.i_manufact_id,
>     d.d_qoy
>   ) tmp1
> -- where
> --   case when avg_quarterly_sales > 0 then abs (sum_sales - avg_quarterly_sales)
/ avg_quarterly_sales else null end > 0.1
> order by
>   -- avg_quarterly_sales,
>   sum_sales,
>   tmp1.imid
> limit 100
> Query failed: RemoteRpcException: Failure while running fragment., Attempted to close
accountor with 1 buffer(s) still allocatedfor QueryId: 2b35963d-aae2-d069-c5cc-c8ce3d414cf6,
MajorFragmentId: 4, MinorFragmentId: 9.
> 	Total 1 allocation(s) of byte size(s): 23058, at stack location:
> 		org.apache.drill.exec.memory.TopLevelAllocator$ChildAllocator.takeOwnership(TopLevelAllocator.java:197)
> 		org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:119)
> 		org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:48)
> 		org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:194)
> 		org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:173)
> 		io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> 		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> 		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
> 		io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> 		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> 		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
> 		io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161)
> 		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> 		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
> 		io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
> 		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> 		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
> 		io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
> 		io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130)
> 		io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
> 		io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> 		io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> 		io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> 		io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
> 		java.lang.Thread.run(Thread.java:744)
>  



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

Mime
View raw message