Skip to content

Commit 203dfed

Browse files
authored
Merge pull request #325 from SumoLogic/ssong-error-handling1
fix filter plugin error with kubernetes_meta_reduce
2 parents 7d939a2 + acb0568 commit 203dfed

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

fluent-plugin-kubernetes-sumologic/lib/fluent/plugin/filter_kubernetes_sumologic.rb

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -158,12 +158,14 @@ def filter(tag, time, record)
158158
end
159159
if annotations["sumologic.com/kubernetes_meta_reduce"] == "true" || annotations["sumologic.com/kubernetes_meta_reduce"].nil? && @kubernetes_meta_reduce == true
160160
record.delete("docker")
161-
record["kubernetes"].delete("pod_id")
162-
record["kubernetes"].delete("namespace_id")
163-
record["kubernetes"].delete("labels")
164-
record["kubernetes"].delete("namespace_labels")
165-
record["kubernetes"].delete("master_url")
166-
record["kubernetes"].delete("annotations")
161+
if record.key?("kubernetes") and not record.fetch("kubernetes").nil?
162+
record["kubernetes"].delete("pod_id")
163+
record["kubernetes"].delete("namespace_id")
164+
record["kubernetes"].delete("labels")
165+
record["kubernetes"].delete("namespace_labels")
166+
record["kubernetes"].delete("master_url")
167+
record["kubernetes"].delete("annotations")
168+
end
167169
end
168170
if @add_stream == false
169171
record.delete("stream")

0 commit comments

Comments
 (0)