StormCrawler переходит с 1.6 на 1.8

Я сталкиваюсь со следующей ошибкой при попытке перейти на SC 1.8 (я был на 1.6 раньше). Я установил Storm 1.2.1, ES 6.2.2 в соответствии с рекомендациями, адаптировал конфигурацию ES и топологию семенного инжектора ES. Однако, когда я запускаю его, вот что я получаю:

4845 [Thread-34-enqueue-executor[5 5]] ERROR c.d.s.e.p.StatusUpdaterBolt - Can't connect to ElasticSearch
java.lang.IllegalArgumentException: no hosts provided
        at org.elasticsearch.client.RestClientBuilder.<init>(RestClientBuilder.java:69) ~[patent-crawler-1.8.jar:?]
        at org.elasticsearch.client.RestClient.builder(RestClient.java:120) ~[patent-crawler-1.8.jar:?]
        at com.digitalpebble.stormcrawler.elasticsearch.ElasticSearchConnection.getClient(ElasticSearchConnection.java:96) ~[patent-crawler-1.8.jar:?]
        at com.digitalpebble.stormcrawler.elasticsearch.ElasticSearchConnection.getConnection(ElasticSearchConnection.java:166) ~[patent-crawler-1.8.jar:?]
        at com.digitalpebble.stormcrawler.elasticsearch.persistence.StatusUpdaterBolt.prepare(StatusUpdaterBolt.java:141) [patent-crawler-1.8.jar:?]
        at org.apache.storm.daemon.executor$fn__5043$fn__5056.invoke(executor.clj:803) [storm-core-1.2.1.jar:1.2.1]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:482) [storm-core-1.2.1.jar:1.2.1]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_161]

Кто-нибудь сталкивался с подобной проблемой? Спасибо!

Источник

2 ответа

Решение

Что у вас в конфиге для es.status.addresses? Старое значение должно быть совместимым

Источник

Извините, моя ошибка, я был слишком быстр с копированием / вставкой в ​​моем ES yaml. У меня была запись индекса (es.indexer.addresses), реплицированная для всех индексов... Теперь она работает нормально. Спасибо Жюльен за подсказку!

Источник
Другие вопросы по тегам