buffer: Fix log message for chunk_limit_records case. fix #3072

Signed-off-by: Masahiro Nakagawa <repeatedly@gmail.com>
fluent · Jul 21, 2020 · e80d532 · e80d532
1 parent b03ee59
commit e80d532
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