Hello, I'm using a CDH 5.3.0 cluster, and having problems when trying to use SolrJ (version 4.4.0-cdh5.3.0) to insert a document into Solr. According to the documentation, I can use code like the following to interact with ZooKeeper controlled SolrCloud server: import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.CloudSolrServer;
import org.apache.solr.common.SolrInputDocument;
import java.io.IOException;
public class standaloneCloud {
public static void main(String [] args) throws IOException, SolrServerException {
String myId = "myID";
String myUri = "this is for sure something usefull and stuff!";
String myLangCode = "ru";
String myType = "my_type!";
String zkHostString = "localhost:2181/solr"; // SSH tunnelled to ZooKeeper
CloudSolrServer server = new CloudSolrServer(zkHostString);
server.setDefaultCollection("collection3");
SolrInputDocument doc = new SolrInputDocument();
doc.addField("id", myId + "___" + "some keyword" );
doc.addField("uri", myUri );
doc.addField("alias", "some keyword" );
doc.addField("langCode", myLangCode );
doc.addField("type", myType);
server.add(doc);
server.commit();
}
} But when I run it, it gives the following exception: Exception in thread "main" org.apache.solr.client.solrj.SolrServerException: No live SolrServers available to handle this request
at org.apache.solr.client.solrj.impl.LBHttpSolrServer.request(LBHttpSolrServer.java:289)
at org.apache.solr.client.solrj.impl.CloudSolrServer.request(CloudSolrServer.java:310)
at org.apache.solr.client.solrj.request.AbstractUpdateRequest.process(AbstractUpdateRequest.java:117)
at org.apache.solr.client.solrj.SolrServer.add(SolrServer.java:116)
at org.apache.solr.client.solrj.SolrServer.add(SolrServer.java:102)
at standaloneCloud.main(standaloneCloud.java:31)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140) I don't understand why it complains about no live Solr servers, because there are live Solr servers, there's a ZooKeeper at the given host:port, and I also checked that it returns the address of a valid Solr server on the cluster. To prove it, on the same cluster, I compile and run the following code that is very similar, only difference being the use of HttpSolrServer directly, instead of CloudSolrServer: import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.common.SolrInputDocument;
public class standalone {
public static void main(String [] args) {
try {
String myId = "myID";
String myUri = "this is for sure something usefull and stuff!";
String myLangCode = "ru";
String myType = "my_type!";
String solrString ="http://node04.demo.hadoop:8983/solr/collection3";
HttpSolrServer server = new HttpSolrServer(solrString);
SolrInputDocument doc = new SolrInputDocument();
doc.addField("id", myId + "___" + "some keyword" );
doc.addField("uri", myUri );
doc.addField("alias", "some keyword" );
doc.addField("langCode", myLangCode );
doc.addField("type", myType );
server.add(doc);
server.commit();
} catch (Exception e) {
System.out.println(e);
}
}
} The code above works perfectly fine and inserts the document to Solr to be indexed without any exceptions. So, why can't I use CloudSolrServer and send my document via ZooKeeper when I'm using SolrJ?
... View more
