Don't call commit_write when can't get ack

fluent · May 24, 2017 · ae69f72 · ae69f72
1 parent f8c4554
commit ae69f72
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb
@@ -495,7 +495,7 @@ def ack_reader
 
           readable_sockets.each do |sock|
             chunk_id = read_ack_from_sock(sock, unpacker)
-            commit_write(chunk_id)
+            commit_write(chunk_id) if chunk_id
           end
         rescue => e
           log.error "unexpected error while receiving ack", error: e