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

Fix PQ stats with ruby pipeline

Browse source 
Stats were not being collected when the PQ was enabled due to the
queue class type check not being updated after Javafication of
WrappedAckedQueue

Fixes https://github.com/elastic/x-pack-logstash/issues/335

Fixes #9116
This commit is contained in:
Rob Bavey 2018-02-08 11:07:18 -05:00
parent f60b600c27
commit e3d9aed365
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -679,7 +679,7 @@ module LogStash; class Pipeline < BasePipeline
def collect_stats
pipeline_metric = @metric.namespace([:stats, :pipelines, pipeline_id.to_s.to_sym, :queue])
pipeline_metric.gauge(:type, settings.get("queue.type"))
if @queue.is_a?(LogStash::Util::WrappedAckedQueue) && @queue.queue.is_a?(LogStash::AckedQueue)
if @queue.is_a?(LogStash::WrappedAckedQueue) && @queue.queue.is_a?(LogStash::AckedQueue)
queue = @queue.queue
dir_path = queue.dir_path
file_store = Files.get_file_store(Paths.get(dir_path))