Buffer: Fix NoMethodError with empty unstaged chunk arrays (fluent#4303)

Signed-off-by: Alex Doolittle <alex_doolittle@uhaul.com>
daipom · Oct 31, 2023 · 36220e5 · 36220e5
1 parent 52e46f0
commit 36220e5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/plugin/buffer.rb b/lib/fluent/plugin/buffer.rb
@@ -417,7 +417,7 @@ def write(metadata_and_data, format: nil, size: nil, enqueue: false)
             if c.staged? && (enqueue || chunk_size_full?(c))
               m = c.metadata
               enqueue_chunk(m)
-              if unstaged_chunks[m]
+              if unstaged_chunks[m] && !unstaged_chunks[m].empty?
                 u = unstaged_chunks[m].pop
                 u.synchronize do
                   if u.unstaged? && !chunk_size_full?(u)