lib/fluent/plugin/in_sql.rb in fluent-plugin-sql-0.4.3 vs lib/fluent/plugin/in_sql.rb in fluent-plugin-sql-0.4.4

@@ -123,10 +123,10 @@
             me.add(time, record)
             last_record = record
           end
         end
 
-        last_record = last_record.dup  # some plugin rewrites record :(
+        last_record = last_record.dup if last_record  # some plugin rewrites record :(
         @router.emit_stream(@tag, me)
 
         return last_record
       end
     end