title: logstash - Exception in thread ">output" org.elasticsearch.discovery.MasterNotDiscoveredException: waited for [30s]
body: <p>Log stash is 100% a disaster for me.  I am using LS 1.4.1 and ES 1.02 in the same machine.  </p>
  
  <p>Here is how I start logstash indexer:</p>
  
  <pre><code>/usr/local/share/logstash-1.4.1/bin/logstash -f /usr/local/share/logstash.indexer.config
  input {
    redis {
      host =&gt; "redis.queue.do.development.sf.test.com"
      data_type =&gt; "list"
      key =&gt; "logstash"
      codec =&gt; json
    }
  }
  
  output {
          stdout { }
          elasticsearch {
                  bind_host =&gt; "127.0.0.1"
                  port =&gt; "9300"
          }
  }
  </code></pre>
  
  <p>ES I set:</p>
  
  <pre><code>network.bind_host: 127.0.0.1
  discovery.zen.ping.multicast.enabled: false
  discovery.zen.ping.unicast.hosts: ["127.0.0.1:9300"]
  </code></pre>
  
  <p>And wow..this is what I get:</p>
  
  <pre><code>/usr/local/share/logstash-1.4.1/bin/logstash -f /usr/local/share/logstash.indexer.config
  Using milestone 2 input plugin 'redis'. This plugin should be stable, but if you see strange behavior, please let us know! For more information on plugin milestones, see http://logstash.net/docs/1.4.1/plugin-milestones {:level=&gt;:warn}
  log4j, [2014-05-29T12:02:29.545]  WARN: org.elasticsearch.discovery: [logstash-do-logstash-sf-development-20140527082230-866-2010] waited for 30s and no initial state was set by the discovery
  Exception in thread "&gt;output" org.elasticsearch.discovery.MasterNotDiscoveredException: waited for [30s]
      at org.elasticsearch.action.support.master.TransportMasterNodeOperationAction$3.onTimeout(org/elasticsearch/action/support/master/TransportMasterNodeOperationAction.java:180)
      at org.elasticsearch.cluster.service.InternalClusterService$NotifyTimeout.run(org/elasticsearch/cluster/service/InternalClusterService.java:492)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(java/util/concurrent/ThreadPoolExecutor.java:1145)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(java/util/concurrent/ThreadPoolExecutor.java:615)
      at java.lang.Thread.run(java/lang/Thread.java:744)
  </code></pre>