accumulo-notifications mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Josh Elser (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (ACCUMULO-3926) "Stream already closed" exceptions from Thrift connections
Date Mon, 06 Jul 2015 19:17:05 GMT

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

Josh Elser updated ACCUMULO-3926:
---------------------------------
    Summary: "Stream already closed" exceptions from Thrift connections  (was: "Stream already
closed" exceptions from Thrift connections on newer Hadoop)

> "Stream already closed" exceptions from Thrift connections
> ----------------------------------------------------------
>
>                 Key: ACCUMULO-3926
>                 URL: https://issues.apache.org/jira/browse/ACCUMULO-3926
>             Project: Accumulo
>          Issue Type: Bug
>          Components: client
>            Reporter: Josh Elser
>            Assignee: Josh Elser
>             Fix For: 1.6.4, 1.7.1, 1.8.0
>
>
> Hadoop-2.7 (.0 or .1, I'm not sure anymore) added a warning when a stream was being closed
that was already closed. It appears that this hits us. Noticed this frequently during randomwalk:
> {noformat}
> 29 05:20:17,446 [transport.TIOStreamTransport] WARN : Error closing output stream.
> java.io.IOException: The stream is closed
>         at org.apache.hadoop.net.SocketOutputStream.write(SocketOutputStream.java:118)
>         at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82)
>         at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140)
>         at java.io.FilterOutputStream.close(FilterOutputStream.java:158)
>         at org.apache.thrift.transport.TIOStreamTransport.close(TIOStreamTransport.java:110)
>         at org.apache.thrift.transport.TFramedTransport.close(TFramedTransport.java:89)
>         at org.apache.accumulo.core.client.impl.ThriftTransportPool$CachedTTransport.close(ThriftTransportPool.java:309)
>         at org.apache.accumulo.core.client.impl.ThriftTransportPool.returnTransport(ThriftTransportPool.java:571)
>         at org.apache.accumulo.core.rpc.ThriftUtil.returnClient(ThriftUtil.java:147)
>         at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:686)
>         at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:349)
>         at org.apache.htrace.wrappers.TraceRunnable.run(TraceRunnable.java:57)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
>         at org.apache.accumulo.fate.util.LoggingRunnable.run(LoggingRunnable.java:35)
>         at java.lang.Thread.run(Thread.java:745)
> {noformat}



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

Mime
View raw message