You are viewing a plain text version of this content. The canonical link for it is here.
Posted to solr-user@lucene.apache.org by Roshan Kamble <Ro...@smartstreamrdu.com> on 2016/07/06 09:09:26 UTC
RE: IO Exception : Truncated chunk for WORKER collection for paraller stream Join Query

Error is observed on WORKER collection.

Below is the error coming at solr instance.

ERROR (qtp796684896-894) [c:WORKER s:shard1 r:core_node6 x:WORKER_shard1_replica2] o.a.s.s.HttpSolrCall null:org.apache.http.TruncatedChunkException: Truncated chunk ( expe
cted size: 32768; actual size: 28568)
        at org.apache.http.impl.io.ChunkedInputStream.read(ChunkedInputStream.java:200)
        at org.apache.http.impl.io.ChunkedInputStream.read(ChunkedInputStream.java:215)
        at org.apache.http.impl.io.ChunkedInputStream.close(ChunkedInputStream.java:316)
        at org.apache.http.conn.BasicManagedEntity.streamClosed(BasicManagedEntity.java:164)
        at org.apache.http.conn.EofSensorInputStream.checkClose(EofSensorInputStream.java:228)
        at org.apache.http.conn.EofSensorInputStream.close(EofSensorInputStream.java:174)
        at sun.nio.cs.StreamDecoder.implClose(StreamDecoder.java:378)
        at sun.nio.cs.StreamDecoder.close(StreamDecoder.java:193)
        at java.io.InputStreamReader.close(InputStreamReader.java:199)
        at org.apache.solr.client.solrj.io.stream.JSONTupleStream.close(JSONTupleStream.java:91)
        at org.apache.solr.client.solrj.io.stream.SolrStream.close(SolrStream.java:159)
        at org.apache.solr.client.solrj.io.stream.CloudSolrStream.close(CloudSolrStream.java:374)
        at org.apache.solr.client.solrj.io.stream.PushBackStream.close(PushBackStream.java:69)
        at org.apache.solr.client.solrj.io.stream.JoinStream.close(JoinStream.java:124)
        at org.apache.solr.client.solrj.io.stream.ExceptionStream.close(ExceptionStream.java:79)
        at org.apache.solr.handler.StreamHandler$TimerStream.close(StreamHandler.java:357)
        at org.apache.solr.response.TextResponseWriter.writeTupleStream(TextResponseWriter.java:317)
        at org.apache.solr.response.TextResponseWriter.writeVal(TextResponseWriter.java:167)
        at org.apache.solr.response.JSONWriter.writeNamedListAsMapWithDups(JSONResponseWriter.java:183)
        at org.apache.solr.response.JSONWriter.writeNamedList(JSONResponseWriter.java:299)
        at org.apache.solr.response.JSONWriter.writeResponse(JSONResponseWriter.java:95)
        at org.apache.solr.response.JSONResponseWriter.write(JSONResponseWriter.java:60)
        at org.apache.solr.response.QueryResponseWriterUtil.writeQueryResponse(QueryResponseWriterUtil.java:65)
        at org.apache.solr.servlet.HttpSolrCall.writeResponse(HttpSolrCall.java:725)
        at org.apache.solr.servlet.HttpSolrCall.call(HttpSolrCall.java:469)
        at org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:229)
        at org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:184)
        at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1668)
        at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:581)
        at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
        at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:548)
        at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:226)
        at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1160)
        at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:511)
        at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
        at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1092)
        at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
        at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:213)
        at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:119)
        at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:134)
        at org.eclipse.jetty.server.Server.handle(Server.java:518)
        at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:308)
        at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:244)
        at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:273)
        at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:95)
        at org.eclipse.jetty.io.SelectChannelEndPoint$2.run(SelectChannelEndPoint.java:93)
        at org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceAndRun(ExecuteProduceConsume.java:246)
        at org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.run(ExecuteProduceConsume.java:156)
        at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:654)
        at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
        at java.lang.Thread.run(Thread.java:745)

-----Original Message-----
From: Joel Bernstein [mailto:joelsolr@gmail.com]
Sent: Thursday, June 30, 2016 1:02 AM
To: solr-user@lucene.apache.org
Subject: Re: IO Exception : Truncated chunk for WORKER collection for paraller stream Join Query

Does this log come from the worker node or from the shards?

It would be good to see the error logs from the server that this node was talking to when the exception was thrown.


Joel Bernstein
http://joelsolr.blogspot.com/

On Tue, Jun 28, 2016 at 1:06 PM, Roshan Kamble < Roshan.Kamble@smartstreamrdu.com> wrote:

> Hello,
>
> we are using Solr 6.0.0 in CloudMode with 3 physical nodes and 3
> shards per collection.
>
>
> we are using ParallelStream for our join searches.
>
>
> Below error is observed when while searching with join query.
>
>
> java.util.concurrent.ExecutionException: java.io.IOException: -->
> http://XX:XX:XX:XX:8983/solr/WORKER_shard3_replica2/:Truncated chunk (
> expected size: 32768; actual size: 11096) at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> at java.util.concurrent.FutureTask.get(FutureTask.java:192)
> at
> org.apache.solr.client.solrj.io.stream.CloudSolrStream.openStreams(Clo
> udSolrStream.java:355)
> ... 70 more
> Caused by: java.io.IOException: -->
> http://XX:XX:XX:XX?:8983/solr/WORKER_shard3_replica2/:Truncated
> chunk ( expected size: 32768; actual size: 11096) at
> org.apache.solr.client.solrj.io.stream.SolrStream.read(SolrStream.java
> :201)
> at
> org.apache.solr.client.solrj.io.stream.CloudSolrStream$TupleWrapper.ne
> xt(CloudSolrStream.java:449)
> at
> org.apache.solr.client.solrj.io.stream.CloudSolrStream$StreamOpener.ca
> ll(CloudSolrStream.java:472)
> at
> org.apache.solr.client.solrj.io.stream.CloudSolrStream$StreamOpener.ca
> ll(CloudSolrStream.java:459) at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> org.apache.solr.common.util.ExecutorUtil$MDCAwareThreadPoolExecutor.la
> mbda$execute$0(ExecutorUtil.java:229)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.j
> ava:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.
> java:617)
> ... 1 more
>
>
> Regards,
> Roshan Kamble
>
>
> ________________________________
> The information in this email is confidential and may be legally
> privileged. It is intended solely for the addressee. Access to this
> email by anyone else is unauthorised. If you are not the intended
> recipient, any disclosure, copying, distribution or any action taken
> or omitted to be taken in reliance on it, is prohibited and may be unlawful.
>
________________________________
 The information in this email is confidential and may be legally privileged. It is intended solely for the addressee. Access to this email by anyone else is unauthorised. If you are not the intended recipient, any disclosure, copying, distribution or any action taken or omitted to be taken in reliance on it, is prohibited and may be unlawful.