Fix fluentd plugin when kubernetes labels were missing (#3358)

When kubernetes labels were missing in the received data, plugin failed
with error "undefined method `each_key' for nil:NilClass".
k43
Filip Poboril 4 years ago committed by GitHub
parent 6ea7122777
commit 8c98ee267c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 8
      cmd/fluentd/lib/fluent/plugin/out_loki.rb

@ -306,9 +306,11 @@ module Fluent
if @extract_kubernetes_labels && record.key?('kubernetes')
kubernetes_labels = record['kubernetes']['labels']
kubernetes_labels.each_key do |l|
new_key = l.gsub(%r{[.\-\/]}, '_')
chunk_labels[new_key] = kubernetes_labels[l]
if !kubernetes_labels.nil?
kubernetes_labels.each_key do |l|
new_key = l.gsub(%r{[.\-\/]}, '_')
chunk_labels[new_key] = kubernetes_labels[l]
end
end
end

Loading…
Cancel
Save