Version 0.0.4

epimorphics · Sep 25, 2024 · 49958fb · 49958fb
1 parent d9c3992
commit 49958fb
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-0.0.3
+0.0.4
diff --git a/lib/fluent/plugin/filter_flatten.rb b/lib/fluent/plugin/filter_flatten.rb
@@ -40,10 +40,18 @@ def filter(tag, time, record)
     end
 
     def flatten(record)
+      unless @field.to_s.length > 0
+        raise Fluent::ConfigError, "Invalid invocation: field not defined"
+      end
+
       newrecord = {}
 
       record.each do |key, value|
-        newkey = key.gsub(/\./, @separator)
+        if key.match(@field)
+          newkey = key.gsub(/\./, @separator)
+        else
+          newkey = key
+        end
 
         # Recurse hashes and arrays:
         if @recurse