Revision 48892
Added by Claudio Atzori over 6 years ago
DedupIndexFeedMapper.java | ||
---|---|---|
15 | 15 |
import org.apache.hadoop.hbase.util.Bytes; |
16 | 16 |
import org.apache.hadoop.io.Text; |
17 | 17 |
import org.apache.solr.client.solrj.SolrServerException; |
18 |
import org.apache.solr.client.solrj.impl.CloudSolrServer;
|
|
18 |
import org.apache.solr.client.solrj.impl.CloudSolrClient;
|
|
19 | 19 |
import org.apache.solr.client.solrj.response.SolrPingResponse; |
20 | 20 |
import org.apache.solr.client.solrj.response.UpdateResponse; |
21 | 21 |
import org.apache.solr.common.SolrInputDocument; |
... | ... | |
35 | 35 |
|
36 | 36 |
private static final Log log = LogFactory.getLog(DedupIndexFeedMapper.class); // NOPMD by marko on 11/24/08 5:02 PM |
37 | 37 |
|
38 |
private CloudSolrServer solrServer;
|
|
38 |
private CloudSolrClient solrServer;
|
|
39 | 39 |
|
40 | 40 |
private String dsId; |
41 | 41 |
|
... | ... | |
99 | 99 |
while (true) { |
100 | 100 |
try { |
101 | 101 |
log.info("initializing solr server..."); |
102 |
solrServer = new CloudSolrServer(baseURL); |
|
102 |
solrServer = new CloudSolrClient.Builder() |
|
103 |
.withZkHost(baseURL) |
|
104 |
.build(); |
|
103 | 105 |
|
104 | 106 |
solrServer.connect(); |
105 | 107 |
|
... | ... | |
115 | 117 |
|
116 | 118 |
} catch (final Throwable e) { |
117 | 119 |
if (solrServer != null) { |
118 |
solrServer.shutdown();
|
|
120 |
solrServer.close();
|
|
119 | 121 |
} |
120 | 122 |
context.getCounter("index init", e.getMessage()).increment(1); |
121 | 123 |
log.info(String.format("failed to init solr client wait %dms", backoffTimeMs)); |
... | ... | |
205 | 207 |
} |
206 | 208 |
log.info("\nwaiting " + shutdownWaitTime + "ms before shutdown"); |
207 | 209 |
Thread.sleep(shutdownWaitTime); |
208 |
solrServer.shutdown();
|
|
210 |
solrServer.close();
|
|
209 | 211 |
} catch (final SolrServerException e) { |
210 | 212 |
System.err.println("couldn't shutdown server " + e.getMessage()); |
211 | 213 |
} |
Also available in: Unified diff
upgraded solr version to 6.6.0