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".
grafana · Mar 3, 2021 · 8c98ee2 · 8c98ee2
1 parent 6ea7122
commit 8c98ee2
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/cmd/fluentd/lib/fluent/plugin/out_loki.rb b/cmd/fluentd/lib/fluent/plugin/out_loki.rb
@@ -306,9 +306,11 @@ def line_to_loki(record)
 
           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