Return-Path: X-Original-To: apmail-drill-issues-archive@minotaur.apache.org Delivered-To: apmail-drill-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E395117A1F for ; Thu, 29 Jan 2015 18:32:33 +0000 (UTC) Received: (qmail 97624 invoked by uid 500); 29 Jan 2015 18:32:34 -0000 Delivered-To: apmail-drill-issues-archive@drill.apache.org Received: (qmail 97594 invoked by uid 500); 29 Jan 2015 18:32:34 -0000 Mailing-List: contact issues-help@drill.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@drill.apache.org Delivered-To: mailing list issues@drill.apache.org Received: (qmail 97584 invoked by uid 99); 29 Jan 2015 18:32:34 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 29 Jan 2015 18:32:34 +0000 Date: Thu, 29 Jan 2015 18:32:34 +0000 (UTC) From: "Krystal (JIRA)" To: issues@drill.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (DRILL-2117) tpcds impala q53 query randomly fails with memory leak MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ 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)