lucene-solr-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Roshan Kamble <Roshan.Kam...@smartstreamrdu.com>
Subject RE: IO Exception : Truncated chunk for WORKER collection for paraller stream Join Query
Date Wed, 06 Jul 2016 09:09:26 GMT
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.
Mime
View raw message