Skip to content

Instantly share code, notes, and snippets.

❯ curl -s localhost:9600/_node/stats | jq '.pipelines.main.plugins.filters[] | select(.events.in!=.events.out)'
{
  "id": "75afda0f03a5af46279c4cba9408ca87664b9c988bf477e2a2cca535e59e856f",
  "events": {
    "in": 1,
 "out": 0,
filebeat.inputs:
- type: logs
paths:
- "/var/log/test/*.log"
- type: csv
paths:
- "/data/*.csv"
package org.logstash.generated;
public final class CompiledDataset461 extends org.logstash.config.ir.compiler.BaseDataset
implements org.logstash.config.ir.compiler.Dataset {
private final java.util.ArrayList field0;
private final org.logstash.generated.CompiledDataset460 field1;
private final org.jruby.RubyArray field2;
private final org.logstash.config.ir.compiler.FilterDelegatorExt field3;
public CompiledDataset461(java.util.Map arguments) {
require_relative "lib/bootstrap/environment"
LogStash::Bundler.setup!({:without => [:build, :development]})
require "logstash-core"
require "logstash/environment"
require "logstash/config/source/local"
require "logstash/java_pipeline"
require "logstash/plugin"
java.lang.System.setProperty("ls.logs", "logs")
java.lang.System.setProperty("ls.log.format", "plain")
[2020-05-07T00:32:32,696][ERROR][logstash.agent ] Failed to execute action {:action=>LogStash::PipelineAction::Reload/pipeline_id:mehe_1, :exception=>"NoMethodError", :message=>"undefined method `length' for nil:NilClass", :backtrace=>["/private/tmp/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/treetop-1.6.10/lib/treetop/runtime/compiled_parser.rb:109:in `has_terminal?'", "/private/tmp/logstash-7.6.1/logstash-core/lib/logstash/compiler/lscl/lscl_grammar.rb:264:in `block in _nt_whitespace'", "org/jruby/RubyKernel.java:1446:in `loop'", "/private/tmp/logstash-7.6.1/logstash-core/lib/logstash/compiler/lscl/lscl_grammar.rb:263:in `_nt_whitespace'", "/private/tmp/logstash-7.6.1/logstash-core/lib/logstash/compiler/lscl/lscl_grammar.rb:124:in `block in _nt_comment'", "org/jruby/RubyKernel.java:1446:in `loop'", "/private/tmp/logstash-7.6.1/logstash-core/lib/logstash/compiler/lscl/lscl_grammar.rb:122:in `_nt_comment'", "/private/tmp/logstash-7.6.1/logstash-core/lib/logstash/compiler/lscl/lscl_grammar.rb:224:i
/tmp/logstash-7.6.0 ❯ bin/logstash -i irb
Sending Logstash logs to /tmp/logstash-7.6.0/logs which is now configured via log4j2.properties
irb(main):001:0> grok_class = LogStash::Plugin.lookup("filter", "grok")
=> LogStash::Filters::Grok
irb(main):002:0> grok = grok_class.new("match" => { "message" => [ "%{WORD:word}", "%{NUMBER:num}" ] })
=> <LogStash::Filters::Grok match=>{"message"=>["%{WORD:word}", "%{NUMBER:num}"]}, id=>"grok_1a49e57c-96f1-4381-b421-0fb93adf6eec", enable_metric=>true, periodic_flush=>false, patterns_files_glob=>"*", break_on_match=>true, named_captures_only=>true, keep_empty_captures=>false, tag_on_failure=>["_grokparsefailure"], timeout_millis=>30000, timeout_scope=>"pattern", tag_on_timeout=>"_groktimeout">
irb(main):003:0> grok.register
# encoding: utf-8
# disclaimer: this code was ripped off from Jordan Sissel's [lumberjack client](https://github.com/elastic/ruby-lumberjack/blob/master/lib/lumberjack/client.rb)
require "socket"
require "zlib"
require "json"
module Lumberjack
SEQUENCE_MAX = (2**32-1).freeze
class Socket
bash-4.2$ jstack 1
2019-11-25 10:12:42
Full thread dump OpenJDK 64-Bit Server VM (11.0.5+10-LTS mixed mode, sharing):
Threads class SMR info:
_java_thread_list=0x00007f1b90001c60, length=17, elements={
0x00007f1bd4013800, 0x00007f1bd409f800, 0x00007f1bd40a1800, 0x00007f1bd40a7000,
0x00007f1bd40a9000, 0x00007f1bd40ab000, 0x00007f1bd40ad000, 0x00007f1bd40db800,
0x00007f1bd40f3000, 0x00007f1bd4415000, 0x00007f1b4c013000, 0x00007f1b4c015800,
0x00007f1b4c017800, 0x00007f1b4c019800, 0x00007f1bd4a89800, 0x00007f1bd4349800,
bash-4.2$ jstack 1
2019-11-25 10:12:42
Full thread dump OpenJDK 64-Bit Server VM (11.0.5+10-LTS mixed mode, sharing):
Threads class SMR info:
_java_thread_list=0x00007f1b90001c60, length=17, elements={
0x00007f1bd4013800, 0x00007f1bd409f800, 0x00007f1bd40a1800, 0x00007f1bd40a7000,
0x00007f1bd40a9000, 0x00007f1bd40ab000, 0x00007f1bd40ad000, 0x00007f1bd40db800,
0x00007f1bd40f3000, 0x00007f1bd4415000, 0x00007f1b4c013000, 0x00007f1b4c015800,
0x00007f1b4c017800, 0x00007f1b4c019800, 0x00007f1bd4a89800, 0x00007f1bd4349800,
input {
generator { message => "!" }
generator { message => "!" }
generator { message => "!" }
generator { message => "!" }
generator { message => "!" }
generator { message => "!" }
generator { message => "!" }
generator { message => "!" }
generator { message => "!" }