Skip to content

Commit face261

Browse files
committed
Added support for 'time' field
1 parent 6cd9aa9 commit face261

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/fluent/plugin/filter_elasticsearch_timestamp_check.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ def shutdown
1616
end
1717

1818
def filter(tag, time, record)
19-
existing = record['timestamp'] || record['@timestamp']
19+
existing = record['@timestamp'] || record['timestamp'] || record['time']
2020
if existing
2121
record['@timestamp'] =
2222
DateTime.parse(existing).strftime('%Y-%m-%dT%H:%M:%S%z')

0 commit comments

Comments
 (0)