# Issues connecting to connecting to elasticsearch from logstash using stdin input **URL:** \ **Category:** Logstash\ **Created:** [May 28, 2015, 1:08pm UTC](https://discuss.elastic.co/t/issues-connecting-to-connecting-to-elasticsearch-from-logstash-using-stdin-input/1468 "2015-05-28T13:08:22Z")\ **Posts on this page:** 5\ **Page:** 1
**Author:** ![Priyanku\_konar](https://avatars.discourse-cdn.com/v4/letter/p/0ea827/32.png) [@Priyanku\_konar](https://discuss.elastic.co/u/Priyanku_konar)\ **Post date:** [May 28, 2015, 1:08pm UTC](https://discuss.elastic.co/t/issues-connecting-to-connecting-to-elasticsearch-from-logstash-using-stdin-input/1468/1 "2015-05-28T13:08:22Z")
Logstash is not able to connect to elasticsearch and giving errors in loop , ## attaching the dump with --debug flag in logstash Logstash startup completed send this message from stdin to elastic search ←[36moutput received {:event=\>{"message"=\>"send this message from stdin to elastic search\r", "@version"=\>"1", "@timestamp"=\>"2015-05-27T17:08:37.742Z", "type"= "human", "inputsource"=\>"stdin", "host"=\>"PriyankuK-MSL"}, :level=\>:debug, :file=\>"(eval)", :line=\>"25", :method=\>"output\_func"}←[0m 2015-05-27T17:08:37.742Z PriyankuK-MSL send this message from stdin to elastic search ←[36mFlushing output {:outgoing\_count=\>1, :time\_since\_last\_flush=\>50.355, :outgoing\_events=\>{nil=\>[["index", {:id=\>nil, :index=\>"logstash-2015.05.27", :\_type= "human", :routing=\>nil}, #@metadataaccessors=#@store={"retry\_count"=\>0}, @lut={}\>, @cancelled =false, @data={"message"=\>"send this message from stdin to elastic search\r", "@version"=\>"1", "@timestamp"=\>"2015-05-27T17:08:37.742Z", "type"=\>"human", "input source"=\>"stdin", "host"=\>"PriyankuK-MSL"}, @metadata={"retry\_count"=\>0}, @accessors=#@store={"message"=\>"send this messag e from stdin to elastic search\r", "@version"=\>"1", "@timestamp"=\>"2015-05-27T17:08:37.742Z", "type"=\>"human", "inputsource"=\>"stdin", "host"=\>"PriyankuK-MSL"}, @lut={"type"=\>[{"message"=\>"send this message from stdin to elastic search\r", "@version"=\>"1", "@timestamp"=\>"2015-05-27T17:08:37.742Z", "type"=\>"human", "inp utsource"=\>"stdin", "host"=\>"PriyankuK-MSL"}, "type"], "inputsource"=\>[{"message"=\>"send this message from stdin to elastic search\r", "@version"=\>"1", "@timest amp"=\>"2015-05-27T17:08:37.742Z", "type"=\>"human", "inputsource"=\>"stdin", "host"=\>"PriyankuK-MSL"}, "inputsource"], "host"=\>[{"message"=\>"send this message fro m stdin to elastic search\r", "@version"=\>"1", "@timestamp"=\>"2015-05-27T17:08:37.742Z", "type"=\>"human", "inputsource"=\>"stdin", "host"=\>"PriyankuK-MSL"}, "hos t"], "message"=\>[{"message"=\>"send this message from stdin to elastic search\r", "@version"=\>"1", "@timestamp"=\>"2015-05-27T17:08:37.742Z", "type"=\>"human", "in putsource"=\>"stdin", "host"=\>"PriyankuK-MSL"}, "message"]}\>\>]]}, :batch\_timeout=\>1, :force=\>nil, :final=\>nil, :level=\>:debug, :file=\>"/Priyanku/elasticsearch/lo gstash/logstash-1.5.0/vendor/bundle/jruby/1.9/gems/stud-0.0.19/lib/stud/buffer.rb", :line=\>"207", :method=\>"buffer\_flush"}←[0m ←[36mSending bulk of actions to client[0]: localhost {:level=\>:debug, :file=\>"/Priyanku/elasticsearch/logstash/logstash-1.5.0/vendor/bundle/jruby/1.9/gems/logst ash-output-elasticsearch-0.2.4-java/lib/logstash/outputs/elasticsearch.rb", :line=\>"461", :method=\>"flush"}←[0m ←[31mGot error to send bulk of actions to elasticsearch server at localhost : blocked by: [SERVICE\_UNAVAILABLE/1/state not recovered / initialized];[SERVICE\_UNA VAILABLE/2/no master]; {:level=\>:error, :file=\>"/Priyanku/elasticsearch/logstash/logstash-1.5.0/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-0.2.4 -java/lib/logstash/outputs/elasticsearch.rb", :line=\>"464", :method=\>"flush"}←[0m ←[33mFailed to flush outgoing items {:outgoing\_count=\>1, :exception=\>org.elasticsearch.cluster.block.ClusterBlockException: blocked by: [SERVICE\_UNAVAILABLE/1/s tate not recovered / initialized];[SERVICE\_UNAVAILABLE/2/no master];, :backtrace=\>["org.elasticsearch.cluster.block.ClusterBlocks.globalBlockedException(org/ela sticsearch/cluster/block/ClusterBlocks.java:151)", "org.elasticsearch.cluster.block.ClusterBlocks.globalBlockedRaiseException(org/elasticsearch/cluster/block/Cl usterBlocks.java:141)", "org.elasticsearch.action.bulk.TransportBulkAction.executeBulk(org/elasticsearch/action/bulk/TransportBulkAction.java:210)", "org.elasti csearch.action.bulk.TransportBulkAction.access$000(org/elasticsearch/action/bulk/TransportBulkAction.java:73)", "org.elasticsearch.action.bulk.TransportBulkActi on$1.onFailure(org/elasticsearch/action/bulk/TransportBulkAction.java:148)", "org.elasticsearch.action.support.TransportAction$ThreadedActionListener$2.run(org/ elasticsearch/action/support/TransportAction.java:137)", "java.util.concurrent.ThreadPoolExecutor.runWorker(java/util/concurrent/ThreadPoolExecutor.java:1142)", "java.util.concurrent.ThreadPoolExecutor$Worker.run(java/util/concurrent/ThreadPoolExecutor.java:617)", "java.lang.Thread.run(java/lang/Thread.java:745)"], :le vel=\>:warn, :file=\>"/Priyanku/elasticsearch/logstash/logstash-1.5.0/vendor/bundle/jruby/1.9/gems/stud-0.0.19/lib/stud/buffer.rb", :line=\>"231", :method=\>"buffer \_flush"}←[0m ## below is the logstash configuration file input { stdin { add\_field =\> {inputsource =\> "stdin"} type =\> "human" # string (optional) } } output { stdout { } elasticsearch { host =\> localhost } } ---
**Author:** ![magnusbaeck](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/magnusbaeck/32/44943_2.png) [@magnusbaeck](https://discuss.elastic.co/u/magnusbaeck)\ **Post date:** [May 28, 2015, 6:25pm UTC](https://discuss.elastic.co/t/issues-connecting-to-connecting-to-elasticsearch-from-logstash-using-stdin-input/1468/2 "2015-05-28T18:25:04Z")
> org.elasticsearch.cluster.block.ClusterBlockException: blocked by: [SERVICE\_UNAVAILABLE/1/s > tate not recovered / initialized];[SERVICE\_UNAVAILABLE/2/no master Your ES cluster doesn't look healthy. What's the output of ``` curl localhost:9200/_cluster/health?pretty ``` ? ---
**Author:** ![Priyanku\_konar](https://avatars.discourse-cdn.com/v4/letter/p/0ea827/32.png) [@Priyanku\_konar](https://discuss.elastic.co/u/Priyanku_konar)\ **Post date:** [June 1, 2015, 5:58am UTC](https://discuss.elastic.co/t/issues-connecting-to-connecting-to-elasticsearch-from-logstash-using-stdin-input/1468/3 "2015-06-01T05:58:29Z")
{ "cluster\_name" : "elasticsearch", "status" : "yellow", "timed\_out" : false, "number\_of\_nodes" : 1, "active\_primary\_shards" : 9, "active\_shards" : 9, "relocating\_shards" : 0, "initializing\_shards" : 0, "unassigned\_shards" : 9, "number\_of\_pending\_tasks" : 0 } ---
**Author:** ![Priyanku\_konar](https://avatars.discourse-cdn.com/v4/letter/p/0ea827/32.png) [@Priyanku\_konar](https://discuss.elastic.co/u/Priyanku_konar)\ **Post date:** [June 1, 2015, 5:59am UTC](https://discuss.elastic.co/t/issues-connecting-to-connecting-to-elasticsearch-from-logstash-using-stdin-input/1468/4 "2015-06-01T05:59:37Z")
I am running elastic search on windows though .I see the satus as yellow but nor sure what am i supposed to do about it ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 5:38am UTC](https://discuss.elastic.co/t/issues-connecting-to-connecting-to-elasticsearch-from-logstash-using-stdin-input/1468/5 "2017-07-06T05:38:57Z")