#8668 fix NPE in pipeline_reporter's worker_states method

Fixes #8669
elastic · Nov 14, 2017 · 1ce2cd9 · 1ce2cd9
1 parent 2573082
commit 1ce2cd9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/logstash-core/lib/logstash/pipeline_reporter.rb b/logstash-core/lib/logstash/pipeline_reporter.rb
@@ -87,7 +87,8 @@ def plugin_threads
   def worker_states(batch_map)
     pipeline.worker_threads.map.with_index do |thread, idx|
       status = thread.status || "dead"
-      inflight_count = batch_map[thread] ? batch_map[thread].size : 0
+      batch = batch_map[thread]
+      inflight_count = batch ? batch.size : 0
       {
         :status => status,
         :alive => thread.alive?,