Merge pull request #3079 from fluent/fix-log-for-chunk_limit_records

buffer: Fix log message for chunk_limit_records case. fix #3072
fluent · Jul 22, 2020 · be905c9 · be905c9
2 parents b03ee59 + e80d532
commit be905c9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/fluent/plugin/buffer.rb b/lib/fluent/plugin/buffer.rb
@@ -604,7 +604,11 @@ def write_once(metadata, data, format: nil, size: nil, &block)
 
             if chunk_size_over?(chunk)
               if format && empty_chunk
-                log.warn "chunk bytes limit exceeds for an emitted event stream: #{adding_bytesize}bytes"
+                if chunk.bytesize > @chunk_limit_size
+                  log.warn "chunk bytes limit exceeds for an emitted event stream: #{adding_bytesize}bytes"
+                else
+                  log.warn "chunk size limit exceeds for an emitted event stream: #{chunk.size}records"
+                end
               end
               chunk.rollback