Skip to content

Instantly share code, notes, and snippets.

@akatreyt
Created March 2, 2016 17:46
Show Gist options
  • Save akatreyt/4531d73d84df2d085b75 to your computer and use it in GitHub Desktop.
Save akatreyt/4531d73d84df2d085b75 to your computer and use it in GitHub Desktop.
Flushing buffer at interval {:instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x75dbe831 @stopping=#<Concurrent::AtomicBoolean:0x3869256a>, @last_flush=2016-03-02 17:44:32 +0000, @flush_thread=#<Thread:0x6f8afd38 run>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0xdf6a0be>, @submit_proc=#<Proc:0x464291b8@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @flush_interval=1, @logger=#<Cabin::Channel:0x3c6ceb11 @subscriber_lock=#<Mutex:0x12bcc815>, @data={}, @metrics=#<Cabin::Metrics:0x27f3e44f @channel=#<Cabin::Channel:0x3c6ceb11 ...>, @metrics={}, @metrics_lock=#<Mutex:0x7d121306>>, @subscribers={12840=>#<Cabin::Outputs::IO:0x60e52f16 @lock=#<Mutex:0x66767f0c>, @io=#<IO:fd 1>>}, @level=:debug>, @buffer=[], @operations_mutex=#<Mutex:0x6d8f2161>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment