From 1802869d80c11d1bb8b49455f983d1d30fcd16ab Mon Sep 17 00:00:00 2001 From: Dan Hermann Date: Thu, 27 Jun 2019 20:00:00 -0500 Subject: [PATCH] remote != remove Fixes #10872 --- logstash-core/lib/logstash/pipelines_registry.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/logstash-core/lib/logstash/pipelines_registry.rb b/logstash-core/lib/logstash/pipelines_registry.rb index 86ed1eacb..51ec9b944 100644 --- a/logstash-core/lib/logstash/pipelines_registry.rb +++ b/logstash-core/lib/logstash/pipelines_registry.rb @@ -86,7 +86,7 @@ module LogStash state = @states.get(pipeline_id) if state.nil? logger.error("Attempted to terminate a pipeline that does not exists", :pipeline_id => pipeline_id) - @states.remote(pipeline_id) + @states.remove(pipeline_id) else yield(state.pipeline) @states.put(pipeline_id, state)