github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -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 23f6d3972e
commit 240048b88d
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) filter_batch(batch)
end end
flush_filters_to_batch(batch, :final => false) if signal.flush? 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. # 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?) break if (shutdown_requested && !draining_queue?)
end end