lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.4 vs lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.5

@@ -235,10 +235,10 @@
       header[INDEX_OP] = meta
       msgs << @dump_proc.call(header) << BODY_DELIMITER
       msgs << @dump_proc.call(record) << BODY_DELIMITER
     end
     if @pipeline
-      msgs << "\"pipeline\" : \"" << @pipeline << "\"" << BODY_DELIMITER
+      msgs << "\"pipeline\",  \"" << @pipeline << "\"" << BODY_DELIMITER
     end
   end
 
   def update_body(record, op)
     update = remove_keys(record)