lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.6 vs lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.7

@@ -234,14 +234,12 @@
     when INDEX_OP
       header[INDEX_OP] = meta
       msgs << @dump_proc.call(header) << BODY_DELIMITER
       msgs << @dump_proc.call(record) << BODY_DELIMITER
     end
-    puts msgs
     if @pipeline
-      msgs << "\"pipeline\",  \"" << @pipeline << "\"" << BODY_DELIMITER
+      msgs << "{\"pipeline\": \"" << @pipeline << "\"}" << BODY_DELIMITER
     end
-    puts msgs
   end
 
   def update_body(record, op)
     update = remove_keys(record)
     body = {"doc".freeze => update}