Не удалось запустить Elasticsearch Sink

Question

Я пытаюсь запустить мой поиск elasticsearch. Однако я получаю следующую ошибку и у меня заканчиваются идеи о том, как ее исправить. Любая помощь приветствуется. Здесь ошибка:

2015-02-10 11: 43: 31234 ОШИБКА org.apache.flume.lifecycle.LifecycleSupervisor: Не удается запустить SinkRunner: {политика: org.apache.flume.sink.DefaultSinkProcessor@79a805d2 counterGroup : {name: null counters: {}}} - следует исключение. java.lang.NoSuchFieldError:. LUCENE_3_6 в org.elasticsearch.Version (Version.java:45) на org.elasticsearch.client.transport.TransportClient (TransportClient.java:168) на org.elasticsearch.client.. transport.TransportClient. (TransportClient.java:123) at org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient.openClient (ElasticSearchTransportClient.java:201) at org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient . (ElasticSearchTransportClient.java:79) at org.apache.flume.sink.elasticsearch.client.ElasticSearchClientFactory.getClient (ElasticSearchClientFactory.java:48) at org.apache.flume.sink.elasticsearch.ElasticSearchSink.start (ElasticSearchSink. java: 357) at org. apache.flume.sink.DefaultSinkProcessor.start (DefaultSinkProcessor.java:46) at org.apache.flume.SinkRunner.start (SinkRunner.java:79) at org.apache.flume.lifecycle.LifecycleSupervisor $ MonitorRunnable.run (LifecycleSupervisor.java:251) на java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:471) на java.util.concurrent.FutureTask.runAndReset (FutureTask.java:304) на java.util. concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 301 (ScheduledThreadPoolExecutor.java:178) в java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.java:293) в java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java : 1145) at java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:615) в java.lang.Thread.run (Thread.java:745)

Я бегу CDH 5.3 и elasticsearch 1.4.2

Answer 1

Я подозреваю, что вы уронили эластичные поисковые банки в FLUME_HOME/lib

Проблема здесь объясняется противоречивыми версиями Elastic Search in Flume. Библиотеки, которые вы предоставили, не совпадают с используемыми вами библиотеками. Флюм 1.5 связан с эластичным поиском 4.9.

Answer 2

Хорошо, понял это после того, как вы, ребята, указали мне в правильном направлении.

Поскольку я использую CHD 5.3, мне нужно было скопировать сборник elasticsearch 1.4.2 в каталог/user/lib/hadoop, а не в каталог flume-ng. После этого он работал отлично.

Спасибо всем за помощь!