Delete empty queued_num field after purging chunks

This should fix the memory-leak bug described in fluent#1918.
eagletmt · Apr 2, 2018 · b13cb0c · b13cb0c
1 parent 39d6911
commit b13cb0c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/fluent/plugin/buffer.rb b/lib/fluent/plugin/buffer.rb
@@ -489,6 +489,7 @@ def purge_chunk(chunk_id)
 
           if metadata && !@stage[metadata] && (!@queued_num[metadata] || @queued_num[metadata] < 1)
             @metadata_list.delete(metadata)
+            @queued_num.delete(metadata)
           end
           log.trace "chunk purged", instance: self.object_id, chunk_id: dump_unique_id_hex(chunk_id), metadata: metadata
         end