diff --git a/lib/fluent/logger/fluent_logger.rb b/lib/fluent/logger/fluent_logger.rb
index b974265..1f24ab3 100644
--- a/lib/fluent/logger/fluent_logger.rb
+++ b/lib/fluent/logger/fluent_logger.rb
@@ -225,15 +225,15 @@ def write(msg)
           end
 
           begin
-            send_data(@pending)
+            data_to_send = @pending
             @pending = nil
+            send_data(data_to_send)
             true
           rescue => e
             set_last_error(e)
             if pending_bytesize > @limit
               @logger.error("FluentLogger: Can't send logs to #{connection_string}: #{$!}")
-              call_buffer_overflow_handler(@pending)
-              @pending = nil
+              call_buffer_overflow_handler(data_to_send)
             end
             @con.close if connect?
             @con = nil