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

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