diff --git a/lib/fluent/plugin/output.rb b/lib/fluent/plugin/output.rb index ca3d50ea0c..7404101cbb 100644 --- a/lib/fluent/plugin/output.rb +++ b/lib/fluent/plugin/output.rb @@ -927,11 +927,14 @@ def metadata(tag, time, record) def calculate_timekey(time) time_int = time.to_i + return @calculate_timekey_last_timekey if @calculate_timekey_last_time_int == time_int + + @calculate_timekey_last_time_int = time_int if @timekey_use_utc - (time_int - (time_int % @timekey)).to_i + @calculate_timekey_last_timekey = (time_int - (time_int % @timekey)).to_i else offset = @calculate_offset ? @calculate_offset.call(time) : @offset - (time_int - ((time_int + offset)% @timekey)).to_i + @calculate_timekey_last_timekey = (time_int - ((time_int + offset) % @timekey)).to_i end end