Merge pull request #23 from knqyf263/fix-load_from_file

Fix error with store_file option

Author: muddydixon

.travis.yml

@@ -1,3 +1,5 @@
+before_install:
+  - gem update bundler
 rvm:
   - 1.9.3
   - 2.0.0

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}"
       s
     end
 

lib/fluent/plugin/out_anomalydetect.rb

@@ -324,7 +324,18 @@ def load_from_file
             @outliers     = stored[:outliers]
             @outlier_bufs = stored[:outlier_bufs]
             @scores       = stored[:scores]
-            @outliers.each {|outlier| outlier.log = log } # @log is not dumped, so have to set at here
+
+            # @log is not dumped, so have to set to @outliers and @scores at here
+            log_proc = Proc.new do |stored_value|
+              if @targets
+                @targets.each {|target| stored_value[target].log = log }
+              elsif @target
+                stored_value[@target].log = log
+              end
+            end
+            @outliers.each_value {|outlier| log_proc.call(outlier) }
+            @scores.each_value {|score| log_proc.call(score) }
+
           else
             log.warn "anomalydetect: configuration param was changed. ignore stored data"
           end