remove explicit clone set up on output workers

Fixes #2876
elastic · Mar 24, 2015 · 4a3c9e7 · 4a3c9e7
1 parent e5ba35e
commit 4a3c9e7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/logstash/outputs/base.rb b/lib/logstash/outputs/base.rb
@@ -69,7 +69,7 @@ def worker_setup
     else
       define_singleton_method(:handle, method(:handle_worker))
       @worker_queue = SizedQueue.new(20)
-      @worker_plugins = @workers.times.map { self.class.new(@original_params.merge("workers" => 1, "codec" => @codec.clone)) }
+      @worker_plugins = @workers.times.map { self.class.new(@original_params.merge("workers" => 1)) }
       @worker_plugins.map.with_index do |plugin, i|
         Thread.new(original_params, @worker_queue) do |params, queue|
           LogStash::Util::set_thread_name(">#{self.class.config_name}.#{i}")