Re: Exception when processing streaming expression

2018-07-24 Thread Christian Spitzlay
Hi, > Am 15.06.2018 um 14:54 schrieb Christian Spitzlay > : > > >> Am 15.06.2018 um 01:23 schrieb Joel Bernstein : >> >> We have to check the behavior of the innerJoin. I suspect that its closing >> the second stream when the first stream his finished. This would cause a >> broken pipe with t

Re: Exception when processing streaming expression

2018-06-15 Thread Christian Spitzlay
> Am 15.06.2018 um 01:23 schrieb Joel Bernstein : > > We have to check the behavior of the innerJoin. I suspect that its closing > the second stream when the first stream his finished. This would cause a > broken pipe with the second stream. The export handler has specific code > that eats the b

Re: Exception when processing streaming expression

2018-06-14 Thread Joel Bernstein
We have to check the behavior of the innerJoin. I suspect that its closing the second stream when the first stream his finished. This would cause a broken pipe with the second stream. The export handler has specific code that eats the broken pipe exception so it doesn't end up in the logs. The sele

Re: Exception when processing streaming expression

2018-06-14 Thread Christian Spitzlay
What does that mean exactly? If I set the rows parameter to 10 the exception still occurs. AFAICT all this happens internally during the processing of the streaming expression. Why wouldn't the select send the EOF tuple when it reaches the end of the documents? Or why wouldn't the rec

Re: Exception when processing streaming expression

2018-06-14 Thread Susmit
Hi, This may be expected if one of the streams is closed early - does not reach to EOF tuple Sent from my iPhone > On Jun 14, 2018, at 9:53 AM, Christian Spitzlay > wrote: > > Here ist one I stripped down as far as I could: > > innerJoin(sort(search(kmm, > q="sds_endpoint_uuid:(2f927a0b\-f

Re: Exception when processing streaming expression

2018-06-14 Thread Christian Spitzlay
Here ist one I stripped down as far as I could: innerJoin(sort(search(kmm, q="sds_endpoint_uuid:(2f927a0b\-fe38\-451e\-9103\-580914a77e82)", fl="sds_endpoint_uuid,sds_to_endpoint_uuid", sort="sds_to_endpoint_uuid ASC", qt="/export"), by="sds_endpoint_uuid ASC"), search(kmm, q=ss_search_api_dat

Re: Exception when processing streaming expression

2018-06-13 Thread Joel Bernstein
Can your provide some example expressions that are causing these exceptions? Joel Bernstein http://joelsolr.blogspot.com/ On Wed, Jun 13, 2018 at 9:02 AM, Christian Spitzlay < christian.spitz...@biologis.com> wrote: > Hi, > > I am seeing a lot of (reproducible) exceptions in my solr log file > w

Exception when processing streaming expression

2018-06-13 Thread Christian Spitzlay
Hi, I am seeing a lot of (reproducible) exceptions in my solr log file when I execute streaming expressions: o.a.s.s.HttpSolrCall Unable to write response, client closed connection or we are shutting down org.eclipse.jetty.io.EofException at org.eclipse.jetty.io.ChannelEndPoint.flush(Ch