We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6f7bcda commit d2c18d8Copy full SHA for d2c18d8
lib/fluent/plugin/filter_concat.rb
@@ -276,7 +276,14 @@ def continuous_line?(text)
276
end
277
278
def overflow?(stream_identity, record)
279
- size = record.keys.sum(&:bytesize) + record.values.sum(&:bytesize)
+ size = if [].respond_to?(:sum)
280
+ record.keys.sum(&:bytesize) + record.values.sum(&:bytesize)
281
+ else
282
+ # Support Ruby 2.3 or earlier
283
+ record.inject(0) do |memo, (key, value)|
284
+ memo + key.bytesize + value.bytesize
285
+ end
286
287
if @buffer_size[stream_identity] + size > @buffer_limit_size
288
@buffer_size[stream_identity] = 0
289
true
0 commit comments