Issues

Select view

Select search mode

 
37 of 37

Using lumberjack to connect two logstash instances hangs after 4999 events are transmitted

Description

Original discussion in newsgroup

Logstash transmits only windows_size - 1 events from a lumberjack output to a lumberjack input. After that it hangs waiting for an ack message.

lumberjack/client.rb:103

public def write_hash(hash) frame = to_frame(hash, inc) -> ack if (@sequence - @last_ack) >= @window_size write frame end

This appears to be fixed in the latest code in https://github.com/elasticsearch/logstash-forwarder, but that code is not present in 1.2.2's flatjar.

Gliffy Diagrams

Details

Assignee

Reporter

Created November 6, 2013 at 10:01 PM
Updated November 7, 2013 at 7:17 AM

Activity

Show:

Boyd Meier November 7, 2013 at 7:17 AM

I was able to patch the flatjar by modifying the lumberjack client.rb file within the jar:

lumberjack/client.rb

--- logstash-1.2.2-original/lumberjack/client.rb 2013-10-22 18:32:08.000000000 -0500 +++ logstash-1.2.2/lumberjack/client.rb 2013-11-06 18:32:50.215927309 -0600 @@ -100,8 +100,8 @@ public def write_hash(hash) frame = to_frame(hash, inc) - ack if (@sequence - @last_ack) >= @window_size write frame + ack if (@sequence - @last_ack) >= @window_size end private