Clear the inflight clock hashmap after stopping a clock

Fixes #5792
2025-04-23 22:27:21 -04:00 · 2016-08-22 12:01:57 -04:00 · 2016-08-22 12:01:57 -04:00 · cf3a424609
commit cf3a424609
parent ab9f3b79be
1 changed files with 1 additions and 0 deletions
--- a/logstash-core/lib/logstash/util/wrapped_synchronous_queue.rb
+++ b/logstash-core/lib/logstash/util/wrapped_synchronous_queue.rb
@ -117,6 +117,7 @@ module LogStash; module Util

      def stop_clock
        @inflight_clocks[Thread.current].each(&:stop)
+        @inflight_clocks.delete(Thread.current)
      end

      def add_starting_metrics(batch)