logstash - Exception in thread ">output" org.elasticsearch.discovery.MasterNotDiscoveredException: waited for [30s] -
log stash 100% disaster me. using ls 1.4.1 , es 1.02 in same machine.
here how start logstash indexer:
/usr/local/share/logstash-1.4.1/bin/logstash -f /usr/local/share/logstash.indexer.config input { redis { host => "redis.queue.do.development.sf.test.com" data_type => "list" key => "logstash" codec => json } } output { stdout { } elasticsearch { bind_host => "127.0.0.1" port => "9300" } }
es set:
network.bind_host: 127.0.0.1 discovery.zen.ping.multicast.enabled: false discovery.zen.ping.unicast.hosts: ["127.0.0.1:9300"]
and wow..this get:
/usr/local/share/logstash-1.4.1/bin/logstash -f /usr/local/share/logstash.indexer.config using milestone 2 input plugin 'redis'. plugin should stable, if see strange behavior, please let know! more information on plugin milestones, see http://logstash.net/docs/1.4.1/plugin-milestones {:level=>:warn} log4j, [2014-05-29t12:02:29.545] warn: org.elasticsearch.discovery: [logstash-do-logstash-sf-development-20140527082230-866-2010] waited 30s , no initial state set discovery exception in thread ">output" org.elasticsearch.discovery.masternotdiscoveredexception: waited [30s] @ org.elasticsearch.action.support.master.transportmasternodeoperationaction$3.ontimeout(org/elasticsearch/action/support/master/transportmasternodeoperationaction.java:180) @ org.elasticsearch.cluster.service.internalclusterservice$notifytimeout.run(org/elasticsearch/cluster/service/internalclusterservice.java:492) @ java.util.concurrent.threadpoolexecutor.runworker(java/util/concurrent/threadpoolexecutor.java:1145) @ java.util.concurrent.threadpoolexecutor$worker.run(java/util/concurrent/threadpoolexecutor.java:615) @ java.lang.thread.run(java/lang/thread.java:744)
see http://logstash.net/docs/1.4.1/outputs/elasticsearch
version note: elasticsearch cluster must running elasticsearch 1.1.1. if use other version of elasticsearch, should set protocol => http in plugin.
so problem logstash doesn't support older es version using without using http
transport.
Comments
Post a Comment