github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-23 22:27:21 -04:00
Code Issues Projects Releases Packages Wiki Activity

Use refresh, not flush, silly me.

Browse source
This commit is contained in:
Jordan Sissel 2013-12-23 15:49:57 -08:00
parent 8dd06bab55
commit 830bc8fc33
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
spec/outputs/elasticsearch.rb
View file

@ -38,7 +38,7 @@ describe "outputs/elasticsearch" do
# We try multiple times to allow final agent flushes as well as allowing
# elasticsearch to finish processing everything.
ftw = FTW::Agent.new
ftw.post!("http://localhost:9200/#{index}/_flush")
ftw.post!("http://localhost:9200/#{index}/_refresh")
# Wait until all events are available.
Stud::try(10.times) do
@ -89,7 +89,7 @@ describe "outputs/elasticsearch" do
agent do
ftw = FTW::Agent.new
ftw.post!("http://localhost:9200/#{index}/_flush")
ftw.post!("http://localhost:9200/#{index}/_refresh")
# Wait until all events are available.
Stud::try(10.times) do
@ -136,7 +136,7 @@ describe "outputs/elasticsearch" do
agent do
ftw = FTW::Agent.new
ftw.post!("http://localhost:9200/#{index}/_flush")
ftw.post!("http://localhost:9200/#{index}/_refresh")
# Wait until all events are available.
Stud::try(10.times) do

2
spec/outputs/elasticsearch_http.rb
View file

@ -38,7 +38,7 @@ describe "outputs/elasticsearch_http" do
# We try multiple times to allow final agent flushes as well as allowing
# elasticsearch to finish processing everything.
ftw = FTW::Agent.new
ftw.post!("http://localhost:9200/#{index}/_flush")
ftw.post!("http://localhost:9200/#{index}/_refresh")
# Wait until all events are available.
Stud::try(10.times) do