diff --git a/cmd/fluentd/lib/fluent/plugin/out_loki.rb b/cmd/fluentd/lib/fluent/plugin/out_loki.rb index 906efc9775d7..f81131d6e1fc 100644 --- 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