Mailing-List: contact solr-user-help@lucene.apache.org; run by ezmlm
Precedence: bulk
Reply-To: solr-user@lucene.apache.org
MIME-Version: 1.0
In-Reply-To: <CAE4tqLOvEU1wAZw4bhSrXU75eOKHXC3WFfRdfXVpQsWt32=QNg@mail.gmail.com>
References: <CANEGTX9VHMphM+hjgST0Uu0pHx-yiVALhQjap0hxGzDkk2NPpg@mail.gmail.com>
 <CAE4tqLOvEU1wAZw4bhSrXU75eOKHXC3WFfRdfXVpQsWt32=QNg@mail.gmail.com>
From: Aman Deep Singh <amandeep.cool99@gmail.com>
Date: Fri, 16 Jun 2017 06:55:30 -0700
Message-ID: <CANEGTX-0jmo+NPU8SxTVVoTmUX-SepkNFmwvVx8qTeeMn=PPLg@mail.gmail.com>
Subject: Re: Possible bug in Solrj-6.6.0
To: solr-user <solr-user@lucene.apache.org>
Content-Type: multipart/alternative; boundary="94eb2c05c04678304d0552142341"
archived-at: Fri, 16 Jun 2017 13:55:40 -0000

--94eb2c05c04678304d0552142341
Content-Type: text/plain; charset="UTF-8"

Thanks Joel,
It is working now
One quick question,as you say that we can use solr client cache multiple
time so can I create a single instance of solr client cache and use it
again and again ,since we are using one single bean for client object.


On 16-Jun-2017 6:28 PM, "Joel Bernstein" <joelsolr@gmail.com> wrote:

The issue is that in 6.6 CloudSolrStream is expecting a StreamContext to be
set. So you'll need to update your code to do this. This was part of
changes made to make streaming work in non-SolrCloud environments.

You also need to create a SolrClientCache which caches the SolrClients.

Example:

SolrClientCache cache = new SolrClientCache();

StreamContext streamContext = new StreamContext();

streamContext.setSolrClientCache(cache);

CloudSolrStream stream = new CloudSolrStream(...);
stream.setStreamContext(streamContext);
stream.open();
....

The SolrClientCache can be shared by multiple requests and should be closed
when the application exits.


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

On Fri, Jun 16, 2017 at 2:17 AM, Aman Deep Singh <amandeep.cool99@gmail.com>
wrote:

> Hi,
> I think their is a possible bug in Solrj version 6.6.0 ,as streaming is
not
> working
> as i have a piece of code
>
> public Set<String> getAllIds(String requestId, String field) {
>     LOG.info("Now Trying to fetch all the ids from SOLR for request Id
> {}", requestId);
>     Map props = new HashMap();
>     props.put("q", field + ":*");
>     props.put("qt", "/export");
>     props.put("sort", field + " asc");
>     props.put("fl", field);
>     Set<String> idSet = new HashSet<>();
>     try (CloudSolrStream cloudSolrStream = new
> CloudSolrStream(cloudSolrClient.getZkHost(),
>             cloudSolrClient.getDefaultCollection(), new
> MapSolrParams(props))) {
>         cloudSolrStream.open();
>         while (true) {
>             Tuple tuple = cloudSolrStream.read();
>             if (tuple.EOF) {
>                 break;
>             }
>             idSet.add(tuple.getString(field));
>         }
>         return idSet;
>     } catch (IOException ex) {
>         LOG.error("Error while fetching the ids from SOLR for request
> Id {} ", requestId, ex);
>     }
>     return Collections.emptySet();
> }
>
>
> This is working in the Solrj 6.5.1 but now it start throwing Error
> after upgrading to solrj-6.6.0
>
> java.io.IOException: java.lang.NullPointerException
>         at org.apache.solr.client.solrj.io.stream.CloudSolrStream.
> constructStreams(CloudSolrStream.java:408)
> ~[solr-solrj-6.6.0.jar:6.6.0 5c7a7b65d2aa7ce5ec96458315c661a18b320241
> - ishan - 2017-05-30 07:32:54]
>         at org.apache.solr.client.solrj.io.stream.CloudSolrStream.
> open(CloudSolrStream.java:299)
> ~[solr-solrj-6.6.0.jar:6.6.0 5c7a7b65d2aa7ce5ec96458315c661a18b320241
> - ishan - 2017-05-30 07:32:54]
>
>
> Thanks,
>
> Aman Deep Singh
>

--94eb2c05c04678304d0552142341--