diff --git a/lib/logstash/filters/clone.rb b/lib/logstash/filters/clone.rb index 1f186bb65..13004f1d2 100644 --- a/lib/logstash/filters/clone.rb +++ b/lib/logstash/filters/clone.rb @@ -23,7 +23,7 @@ class LogStash::Filters::Clone < LogStash::Filters::Base return unless filter?(event) @clones.each do |type| clone = event.clone - clone.type = type + clone["type"] = type filter_matched(clone) @logger.debug("Cloned event", :clone => clone, :event => event)