hive-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Dere (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (HIVE-16651) LlapProtocolClientProxy stack trace when using llap input format
Date Thu, 11 May 2017 18:24:04 GMT

     [ 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)

Mime
View raw message