github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

fixed index variable parsing

Browse source
This commit is contained in:
Paul Czarkowski 2013-01-03 22:52:12 -06:00
parent 25101c6ed0
commit ecc0a6905e
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
lib/logstash/outputs/elasticsearch_river.rb
View file

@ -206,7 +206,7 @@ class LogStash::Outputs::ElasticSearchRiver < LogStash::Outputs::Base
# River events have a format of
# "action\ndata\n"
# where 'action' is index or delete, data is the data to index.
header = { "index" => { "_index" => index, "_type" => type } }
header = { "index" => { "_index" => event.sprintf(@index), "_type" => event.sprintf(@type) } }
if !@document_id.nil?
header["index"]["_id"] = event.sprintf(@document_id)
end