lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.10 vs lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.11

@@ -325,10 +325,10 @@
       meta.clear
       meta["_index".freeze] = target_index
       meta["_type".freeze] = target_type
 
       if @pipeline
-        meta["arguments".freeze] = "{\"pipeline\": \"" << @pipeline << "\"}"
+        meta["pipeline".freeze] = @pipeline 
       end
 
       @meta_config_map.each do |record_key, meta_key|
         meta[meta_key] = record[record_key] if record[record_key]
       end