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

@@ -234,12 +234,14 @@
     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
     end
+    puts msgs
   end
 
   def update_body(record, op)
     update = remove_keys(record)
     body = {"doc".freeze => update}