Logstash, EC2 и эластичный поиск

У меня есть два узла elasticsearch, настроенных в EC2, и я пытаюсь использовать с ним logstash. Я получаю эту ошибку, когда запускаю logstash:

log4j, [2014-02-24T10:45:32.722]  WARN: org.elasticsearch.discovery.zen.ping.unicast: [Ishihara, Shirow] failed to send ping to [[#zen_unicast_1#][inet[/10.110.65.91:9300]]]
org.elasticsearch.transport.RemoteTransportException: Failed to deserialize exception response from stream
Caused by: org.elasticsearch.transport.TransportSerializationException: Failed to deserialize exception response from stream
    at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:169)
    at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:123)
    at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)

Это фрагмент из него. Вот файл conf, который я использую с logstash:

input {
  redis {
    host => "10.110.65.91"
    # these settings should match the output of the agent
    data_type => "list"
    key => "logstash"

    # We use the 'json' codec here because we expect to read
    # json events from redis.
    codec => json
  }
}

output {
  stdout { debug => true debug_format => "json"}

  elasticsearch {
  host => "10.110.65.91"
  cluster => searchbuild
        }
}
~

Я запускаю Logstash на .91 (открывается второе окно терминала). Я что-то упустил?


person Gabriel    schedule 24.02.2014    source источник
comment
Ваша версия Java одинакова на обоих узлах? jontai.me/blog /2013/06/   -  person GPPK    schedule 24.02.2014
comment
Да. Я очень новичок в Logstash. Насколько я понимаю, у меня должен быть третий сервер, который действует как индексатор, а другой — как грузоотправитель, верно?   -  person Gabriel    schedule 24.02.2014
comment
Я починил это. Мне пришлось изменить elasticsearch на elasticsearch_http   -  person Gabriel    schedule 25.02.2014
comment
У меня похожая проблема: logstash больше не запускается автоматически после устранения проблемы с elasticsearch, я создал вопрос, может кто-нибудь помочь мне, пожалуйста?   -  person sop    schedule 23.07.2015


Ответы (1)


Мне пришлось изменить «elasticsearch» на «elasticsearch_http».

Исправлено.

person Gabriel    schedule 25.02.2014
comment
Это не решает исходную проблему, если вы хотите подключиться к elasticsearch не через HTTP-запросы. - person Meekohi; 09.04.2014