google_appengine.rb in logstash-codec-google_appengine-1.4.0

- old
+ new

@@ -21,12 +21,11 @@
         flatten(json).each { |flattenedJson|
           yield LogStash::Event.new(flattenedJson)
         }
       end
     rescue => e
-      @logger.info("Failed to process data", :error => e, :data => data)
-      yield LogStash::Event.new("message" => data, "tags" => ["_googleappengineparsefailure"])
+      @logger.error("Failed to process data", :error => e, :data => data)
     end
   end
 end
 
 private
@@ -40,8 +39,9 @@
   lines = payload['line']
   if lines
     payload.delete('line')
     lines.map { |line| payload.merge(line) }
   else
+    payload['time'] = payload['endTime']
     [payload]
   end
 end