<?xml version="1.0" encoding="UTF-8"?>
<rss xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:taxo="http://purl.org/rss/1.0/modules/taxonomy/" version="2.0">
  <channel>
    <title>question Receiving ZooKeeperException when trying connect to Solr Instance on CDH5.10 using Solrj in Support Questions</title>
    <link>https://community.cloudera.com/t5/Support-Questions/Receiving-ZooKeeperException-when-trying-connect-to-Solr/m-p/53287#M19185</link>
    <description>&lt;P&gt;I am trying to index some data using Solrj.&amp;nbsp; I have a very simple Solrj program:&lt;/P&gt;&lt;P&gt;---------------&lt;/P&gt;&lt;P&gt;public static void main(final String[] args) throws SolrServerException, IOException {&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;final String zkHostString = "dwh-mst-dev01.stor.nccourts.org:2181/solr,dwh-mst-dev02.stor.nccourts.org:2181/solr,dwh-mst-dev03.stor.nccourts.org:2181/solr";&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;final CloudSolrServer solr = new CloudSolrServer(zkHostString);&lt;BR /&gt;&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;final UpdateRequest request = new UpdateRequest();&lt;BR /&gt;&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;request.setAction(UpdateRequest.ACTION.COMMIT, true, true);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;request.setParam("collection", "party_name");&lt;BR /&gt;&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;final SolrInputDocument doc = new SolrInputDocument();&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;final List&amp;lt;String&amp;gt; records = SolrJPopulater.loadSampleData();&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;for (final String record : records) {&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;final String[] fields = record.split(",");&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("id", fields[0]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("county", fields[1]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("year", Integer.parseInt(fields[2]));&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("court_type", fields[3]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("seq_num", Integer.parseInt(fields[4]));&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("party_role", fields[5]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("party_num", Integer.parseInt(fields[6]));&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("party_status", fields[7]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("biz_name", fields[8]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("prefix", fields[9]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("last_name", fields[10]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("first_name", fields[11]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("middle_name", fields[12]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("suffix", fields[13]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("in_regards_to", fields[14]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("case_status", fields[15]);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;doc.addField("row_of_origin", fields[16]);&lt;BR /&gt;&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;final UpdateResponse response = solr.add(doc);&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;System.out.println("status code=" + response.getStatus());&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;}&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp; &amp;nbsp;solr.commit();&lt;BR /&gt;&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;}&lt;/P&gt;&lt;P&gt;The error is happening at this line:&lt;/P&gt;&lt;P&gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; if (zk != null) zk.close();&lt;BR /&gt;&amp;nbsp; --&amp;gt;&amp;gt; &amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR,&lt;BR /&gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; "", e);&lt;/P&gt;&lt;P&gt;&amp;nbsp;&lt;/P&gt;&lt;P&gt;Below is the full trace.&lt;/P&gt;&lt;P&gt;Thanks&lt;/P&gt;&lt;P&gt;--------------&lt;/P&gt;&lt;P&gt;2017-04-06 13:33:19,057 INFO&amp;nbsp; main.logEnv - Client environment:user.dir=C:\cygwin\home\iapima\git\aoc-data-lake-hadoop&lt;BR /&gt;2017-04-06 13:33:19,059 INFO&amp;nbsp; main.&amp;lt;init&amp;gt; - Initiating client connection, connectString=dwh-mst-dev01.stor.nccourts.org:2181/solr,dwh-mst-dev02.stor.nccourts.org:2181/solr,dwh-mst-dev03.stor.nccourts.org:2181/solr sessionTimeout=10000 watcher=org.apache.solr.common.cloud.ConnectionManager@18ef96&lt;BR /&gt;2017-04-06 13:33:19,067 DEBUG main.&amp;lt;clinit&amp;gt; - zookeeper.disableAutoWatchReset is false&lt;BR /&gt;2017-04-06 13:33:19,178 INFO&amp;nbsp; main.waitForConnected - Waiting for client to connect to ZooKeeper&lt;BR /&gt;2017-04-06 13:33:19,183 INFO&amp;nbsp; main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).logStartConnect - Opening socket connection to server dwh-mst-dev01.stor.nccourts.org/10.91.62.104:2181. Will not attempt to authenticate using SASL (unknown error)&lt;BR /&gt;2017-04-06 13:33:19,185 INFO&amp;nbsp; main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).primeConnection - Socket connection established to dwh-mst-dev01.stor.nccourts.org/10.91.62.104:2181, initiating session&lt;BR /&gt;2017-04-06 13:33:19,187 DEBUG main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).primeConnection - Session establishment request sent on dwh-mst-dev01.stor.nccourts.org/10.91.62.104:2181&lt;BR /&gt;2017-04-06 13:33:19,203 INFO&amp;nbsp; main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).onConnected - Session establishment complete on server dwh-mst-dev01.stor.nccourts.org/10.91.62.104:2181, sessionid = 0x15ad7740271bb85, negotiated timeout = 10000&lt;BR /&gt;2017-04-06 13:33:19,205 INFO&amp;nbsp; main-EventThread.process - Watcher org.apache.solr.common.cloud.ConnectionManager@18ef96 name:ZooKeeperConnection Watcher:dwh-mst-dev01.stor.nccourts.org:2181/solr,dwh-mst-dev02.stor.nccourts.org:2181/solr,dwh-mst-dev03.stor.nccourts.org:2181/solr got event WatchedEvent state:SyncConnected type:None path:null path:null type:None&lt;BR /&gt;2017-04-06 13:33:19,206 INFO&amp;nbsp; main.waitForConnected - Client is connected to ZooKeeper&lt;BR /&gt;2017-04-06 13:33:19,206 INFO&amp;nbsp; main.createZkACLProvider - Using default ZkACLProvider&lt;BR /&gt;2017-04-06 13:33:19,220 DEBUG main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).readResponse - Reading reply sessionid:0x15ad7740271bb85, packet:: clientPath:null serverPath:null finished:false header:: 1,3&amp;nbsp; replyHeader:: 1,55835606662,-101&amp;nbsp; request:: '/solr%2Cdwh-mst-dev02.stor.nccourts.org:2181/solr%2Cdwh-mst-dev03.stor.nccourts.org:2181/solr/clusterstate.json,F&amp;nbsp; response:: &amp;nbsp;&lt;BR /&gt;2017-04-06 13:33:19,223 INFO&amp;nbsp; main.makePath - makePath: /clusterstate.json&lt;BR /&gt;2017-04-06 13:33:19,226 DEBUG main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).readResponse - Reading reply sessionid:0x15ad7740271bb85, packet:: clientPath:null serverPath:null finished:false header:: 2,3&amp;nbsp; replyHeader:: 2,55835606662,-101&amp;nbsp; request:: '/solr%2Cdwh-mst-dev02.stor.nccourts.org:2181/solr%2Cdwh-mst-dev03.stor.nccourts.org:2181/solr/clusterstate.json,F&amp;nbsp; response:: &amp;nbsp;&lt;BR /&gt;2017-04-06 13:33:19,349 DEBUG main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).readResponse - Reading reply sessionid:0x15ad7740271bb85, packet:: clientPath:null serverPath:null finished:false header:: 3,1&amp;nbsp; replyHeader:: 3,55835606663,-101&amp;nbsp; request:: '/solr%2Cdwh-mst-dev02.stor.nccourts.org:2181/solr%2Cdwh-mst-dev03.stor.nccourts.org:2181/solr/clusterstate.json,,v{s{31,s{'world,'anyone}}},0&amp;nbsp; response:: &amp;nbsp;&lt;BR /&gt;2017-04-06 13:33:19,353 DEBUG main.close - Closing session: 0x15ad7740271bb85&lt;BR /&gt;2017-04-06 13:33:19,354 DEBUG main.close - Closing client for session: 0x15ad7740271bb85&lt;BR /&gt;2017-04-06 13:33:19,362 DEBUG main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).readResponse - Reading reply sessionid:0x15ad7740271bb85, packet:: clientPath:null serverPath:null finished:false header:: 4,-11&amp;nbsp; replyHeader:: 4,55835606664,0&amp;nbsp; request:: null response:: null&lt;BR /&gt;2017-04-06 13:33:19,363 DEBUG main.disconnect - Disconnecting client for session: 0x15ad7740271bb85&lt;BR /&gt;2017-04-06 13:33:19,363 DEBUG main-SendThread(dwh-mst-dev01.stor.nccourts.org:2181).run - An exception was thrown while closing send thread for session 0x15ad7740271bb85 : Unable to read additional data from server sessionid 0x15ad7740271bb85, likely server has closed socket&lt;BR /&gt;2017-04-06 13:33:19,363 INFO&amp;nbsp; main-EventThread.run - EventThread shut down&lt;BR /&gt;2017-04-06 13:33:19,363 INFO&amp;nbsp; main.close - Session: 0x15ad7740271bb85 closed&lt;BR /&gt;Exception in thread "main" org.apache.solr.common.cloud.ZooKeeperException:&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.client.solrj.impl.CloudSolrServer.connect(CloudSolrServer.java:270)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.client.solrj.impl.CloudSolrServer.request(CloudSolrServer.java:548)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.client.solrj.request.AbstractUpdateRequest.process(AbstractUpdateRequest.java:124)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.client.solrj.SolrServer.add(SolrServer.java:116)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.client.solrj.SolrServer.add(SolrServer.java:102)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.nccourts.hadoop.solr.SolrJPopulater.main(SolrJPopulater.java:52)&lt;BR /&gt;Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /clusterstate.json&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.SolrZkClient$10.execute(SolrZkClient.java:507)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.ZkCmdExecutor.retryOperation(ZkCmdExecutor.java:61)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.SolrZkClient.makePath(SolrZkClient.java:504)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.SolrZkClient.makePath(SolrZkClient.java:461)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.SolrZkClient.makePath(SolrZkClient.java:448)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.SolrZkClient.makePath(SolrZkClient.java:435)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.ZkCmdExecutor.ensureExists(ZkCmdExecutor.java:94)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.ZkCmdExecutor.ensureExists(ZkCmdExecutor.java:84)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.common.cloud.ZkStateReader.createClusterStateWatchersAndUpdate(ZkStateReader.java:295)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;at org.apache.solr.client.solrj.impl.CloudSolrServer.connect(CloudSolrServer.java:261)&lt;BR /&gt;&amp;nbsp;&amp;nbsp; &amp;nbsp;... 5 more&lt;/P&gt;</description>
    <pubDate>Thu, 06 Apr 2017 18:18:57 GMT</pubDate>
    <dc:creator>imad87</dc:creator>
    <dc:date>2017-04-06T18:18:57Z</dc:date>
  </channel>
</rss>

