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

#7990 bring back batch acking for PQ

Browse source 
Fixes #7991
This commit is contained in:
Armin 2017-08-14 16:50:20 +02:00 • committed by Armin Braun
parent 858500c02d
commit 8a9a1f28bf
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
logstash-core/lib/logstash/pipeline.rb
View file

@ -477,7 +477,10 @@ module LogStash; class Pipeline < BasePipeline
filter_batch(batch)
end
flush_filters_to_batch(batch, :final => false) if signal.flush?
output_batch(batch) if batch.size > 0
if batch.size > 0
output_batch(batch)
@filter_queue_client.close_batch(batch)
end
# keep break at end of loop, after the read_batch operation, some pipeline specs rely on this "final read_batch" before shutdown.
break if (shutdown_requested && !draining_queue?)
end