Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id A54BB200C63 for ; Thu, 11 May 2017 20:24:07 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id A3F0D160BC7; Thu, 11 May 2017 18:24:07 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id EA5CC160BB3 for ; Thu, 11 May 2017 20:24:06 +0200 (CEST) Received: (qmail 23199 invoked by uid 500); 11 May 2017 18:24:06 -0000 Mailing-List: contact issues-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hive.apache.org Delivered-To: mailing list issues@hive.apache.org Received: (qmail 23190 invoked by uid 99); 11 May 2017 18:24:06 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 May 2017 18:24:06 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id AB5FBC277D for ; Thu, 11 May 2017 18:24:05 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -99.202 X-Spam-Level: X-Spam-Status: No, score=-99.202 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id IZ_K-_H5lwwa for ; Thu, 11 May 2017 18:24:05 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id B81FF5F398 for ; Thu, 11 May 2017 18:24:04 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 44271E02C7 for ; Thu, 11 May 2017 18:24:04 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 0B50121E09 for ; Thu, 11 May 2017 18:24:04 +0000 (UTC) Date: Thu, 11 May 2017 18:24:04 +0000 (UTC) From: "Jason Dere (JIRA)" To: issues@hive.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (HIVE-16651) LlapProtocolClientProxy stack trace when using llap input format MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Thu, 11 May 2017 18:24:07 -0000 [ https://issues.apache.org/jira/browse/HIVE-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Dere updated HIVE-16651: ------------------------------ Attachment: HIVE-16651.1.patch Looks like this has to do with cancelling the requestManagerFuture in LlapProtocolClientProxy. Patch to ignore CancellationException in the FuturesCallback. I suppose another fix for this might be to avoid cancelling the future in the first place. [~sseth], can you review? > LlapProtocolClientProxy stack trace when using llap input format > ---------------------------------------------------------------- > > Key: HIVE-16651 > URL: https://issues.apache.org/jira/browse/HIVE-16651 > Project: Hive > Issue Type: Sub-task > Components: llap > Reporter: Jason Dere > Assignee: Jason Dere > Attachments: HIVE-16651.1.patch > > > Seeing this after LlapBaseRecordReader.close(): > {noformat} > 16/06/28 22:05:32 WARN LlapProtocolClientProxy: RequestManager shutdown with error > java.util.concurrent.CancellationException > at java.util.concurrent.FutureTask.report(FutureTask.java:121) > at java.util.concurrent.FutureTask.get(FutureTask.java:192) > at com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly(Uninterruptibles.java:135) > at com.google.common.util.concurrent.Futures$4.run(Futures.java:1170) > at com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297) > at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156) > at com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145) > at com.google.common.util.concurrent.ListenableFutureTask.done(ListenableFutureTask.java:91) > at java.util.concurrent.FutureTask.finishCompletion(FutureTask.java:384) > at java.util.concurrent.FutureTask.cancel(FutureTask.java:180) > at org.apache.hadoop.hive.llap.tez.LlapProtocolClientProxy.serviceStop(LlapProtocolClientProxy.java:131) > at org.apache.hadoop.service.AbstractService.stop(AbstractService.java:221) > at org.apache.hadoop.hive.llap.ext.LlapTaskUmbilicalExternalClient.serviceStop(LlapTaskUmbilicalExternalClient.java:135) > at org.apache.hadoop.service.AbstractService.stop(AbstractService.java:221) > at org.apache.hadoop.service.AbstractService.close(AbstractService.java:250) > at org.apache.hadoop.hive.llap.LlapBaseRecordReader.close(LlapBaseRecordReader.java:84) > at org.apache.hadoop.hive.llap.LlapRowRecordReader.close(LlapRowRecordReader.java:80) > {noformat} -- This message was sent by Atlassian JIRA (v6.3.15#6346)