Fixed assign the Fluent::Log to Fluent::ChangeFinder

lib/fluent/plugin/change_finder.rb

@@ -69,7 +69,7 @@ def next(x)
 
       p = prob(xt, @sigma, x)
       s = score(p)
-      @log.debug "change_finder:#{Thread.current.object_id} x:#{x} xt:#{xt} p:#{p} s:#{s} term:#{@term} r:#{@r} data:#{@data} mu:#{@mu} sigma:#{@sigma} c:#{@c}"
+      @log.debug "change_finder:#{Thread.current.object_id} x:#{x} xt:#{xt} p:#{p} s:#{s} term:#{@term} r:#{@r} data:#{@data} mu:#{@mu} sigma:#{@sigma} c:#{@c}" if log.respond_to?(:debug)
       s
     end
 

lib/fluent/plugin/out_anomalydetect.rb

@@ -326,18 +326,8 @@ def load_from_file
             @outlier_bufs = stored[:outlier_bufs]
             @scores       = stored[:scores]
 
-            # @log is not dumped, so have to set to @outliers and @scores at here
-            # nil key if @target not exists
-            log_proc = Proc.new do |stored_value|
-              if @targets
-                @targets.each {|target| stored_value[target].log = log }
-              else
-                stored_value[@target].log = log
-              end
-            end
-            @outliers.each_value {|outlier| log_proc.call(outlier) }
-            @scores.each_value {|score| log_proc.call(score) }
-
+            inject_log(@scores)
+            inject_log(@outliers)
           else
             log.warn "anomalydetect: configuration param was changed. ignore stored data"
           end
@@ -347,6 +337,20 @@ def load_from_file
       end
     end
 
+    def inject_log(obj)
+      case obj
+      when Array
+        obj.map{|o| log_injection(o) }
+      when Hash
+        obj.inject({}) do |hash, (k, v)|
+          hash[k] = log_injection(v)
+          hash
+        end
+      else
+        obj.log = log if obj.respond_to?(:log)
+      end
+    end
+
     def store_to_file
       return unless @store_file
       begin