Skip to content

Commit a479a5a

Browse files
authored
Merge pull request #160 from kebe7jun/master
> fix time comparison error.
2 parents c6ba6be + 519b3f2 commit a479a5a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

lib/fluent/plugin/filter_kubernetes_metadata.rb

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,8 @@ def create_time_from_record(record, internal_time)
287287
time_key = @time_fields.detect{ |ii| record.has_key?(ii) }
288288
time = record[time_key]
289289
if time.nil? || time.chop.empty?
290-
return internal_time
290+
# `internal_time` is a Fluent::EventTime, it can't compare with Time.
291+
return Time.at(internal_time.to_f)
291292
end
292293
if ['_SOURCE_REALTIME_TIMESTAMP', '__REALTIME_TIMESTAMP'].include?(time_key)
293294
timei= time.to_i

0 commit comments

Comments
 (0)