Skip to content

Commit

Permalink
Remove unused variable in fluentd output plugin (#4261)
Browse files Browse the repository at this point in the history
I couldn't figure out why this variable is there. If I am missing any global variables by fluentd feel free to close this PR without any notice
  • Loading branch information
MrWong99 authored Oct 12, 2021
1 parent cdde2cf commit 00168b3
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions clients/cmd/fluentd/lib/fluent/plugin/out_loki.rb
Original file line number Diff line number Diff line change
Expand Up @@ -343,10 +343,8 @@ def line_to_loki(record)
# iterate through each chunk and create a loki stream entry
def chunk_to_loki(chunk)
streams = {}
last_time = nil
chunk.each do |time, record|
# each chunk has a unique set of labels
last_time = time if last_time.nil?
result = line_to_loki(record)
chunk_labels = result[:labels]
# initialize a new stream with the chunk_labels if it does not exist
Expand Down

0 comments on commit 00168b3

Please sign in to comment.