首页 > 解决方案 > logstash 丢弃过滤器等待不同工作人员中的 jruby 同步锁定影响性能

问题描述

我的logstash有2个管道,main-pipeline和kafka-pipeline,main-pipeline worker num是16,kafka-pipeline worker num是4,两个conf信息如下:

input {
    kafka {
        bootstrap_servers => "xxx"
        auto_commit_interval_ms => "300"
        group_id => "logstash_main"
        topics => ["xxx"]
        auto_offset_reset => "latest"
        consumer_threads => 2
    }
}

filter {
    grok {
        match => {
            "message" => "customParams=\{%{DATA:data}\}"
        } 
        remove_field => ["message"]
        remove_field => ["host"]
    }
    if ![data] {
        drop {}
    }
}

output{...}

我发现logstash节点的cpu使用率只有150%(节点有4个逻辑cpu核心),然后运行jstack,得到如下信息和附件,我发现不同的worker在等待同一个锁“lock <0x00000006d4d27700 >" 来自 RubyModule.getMethodsForWrite

"[main-pipeline]>worker15" #58 daemon prio=5 os_prio=0 tid=0x00007fed8005f800 nid=0x10a6 waiting for monitor entry [0x00007fed4f9fa000]
   java.lang.Thread.State: BLOCKED (on object monitor)
    at org.jruby.RubyModule.getMethodsForWrite(RubyModule.java:455)
    - waiting to lock <0x00000006d4d27700> (a org.jruby.RubyClass)
    at org.jruby.RubyModule.addMethodAtBootTimeOnly(RubyModule.java:1212)
    at org.jruby.gen.org$jruby$RubyBoolean$True$POPULATOR.populate(org$jruby$RubyBoolean$True$POPULATOR.java:23)
    at org.jruby.RubyModule.defineAnnotatedMethodsIndividually(RubyModule.java:1060)
    at org.jruby.RubyModule.defineAnnotatedMethods(RubyModule.java:947)
    at org.jruby.RubyBoolean.createTrueClass(RubyBoolean.java:121)
    at org.logstash.ext.JrubyEventExtLibrary$RubyEvent.ruby_cancel(JrubyEventExtLibrary.java:141)
    at java.lang.invoke.LambdaForm$DMH/1554547125.invokeSpecial_LL_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/550752602.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1247233941.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1370651081.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1247233941.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1370651081.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/670971910.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.vendor.bundle.jruby.$2_dot_3_dot_0.gems.logstash_minus_filter_minus_drop_minus_3_dot_0_dot_4.lib.logstash.filters.drop.RUBY$method$filter$0(/home/logstash/logstash/vendor/bundle/jruby/2.3.0/gems/logstash-filter-drop-3.0.4/lib/logstash/filters/drop.rb:42)
    at java.lang.invoke.LambdaForm$DMH/1706377736.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/486715174.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1885996206.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filters.base.RUBY$method$do_filter$0(/home/logstash/logstash/logstash-core/lib/logstash/filters/base.rb:145)
    at java.lang.invoke.LambdaForm$DMH/1706377736.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/486715174.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1885996206.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filters.base.RUBY$block$multi_filter$1(/home/logstash/logstash/logstash-core/lib/logstash/filters/base.rb:164)
    at java.lang.invoke.LambdaForm$DMH/1614468244.invokeStatic_L8_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$MH/1970881185.invokeExact_MT(LambdaForm$MH)
    at org.jruby.runtime.CompiledIRBlockBody.yieldDirect(CompiledIRBlockBody.java:156)
    at org.jruby.runtime.BlockBody.yield(BlockBody.java:114)
    at org.jruby.runtime.Block.yield(Block.java:165)
    at org.jruby.RubyArray.each(RubyArray.java:1734)
    at java.lang.invoke.LambdaForm$DMH/140799417.invokeVirtual_L3_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/2092769598.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/19717364.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filters.base.RUBY$method$multi_filter$0(/home/logstash/logstash/logstash-core/lib/logstash/filters/base.rb:161)
    at java.lang.invoke.LambdaForm$DMH/1706377736.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/2043318969.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/19717364.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filter_delegator.RUBY$method$multi_filter$0(/home/logstash/logstash/logstash-core/lib/logstash/filter_delegator.rb:48)
    at java.lang.invoke.LambdaForm$DMH/1269181528.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$MH/770189387.invokeExact_MT(LambdaForm$MH)
    at org.jruby.internal.runtime.methods.CompiledIRMethod.call(CompiledIRMethod.java:103)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.call(MixedModeIRMethod.java:163)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:161)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:314)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.doYield(IRBlockBody.java:186)
    at org.jruby.runtime.BlockBody.yield(BlockBody.java:116)
    at org.jruby.runtime.Block.yield(Block.java:165)
    at org.jruby.RubyArray.each(RubyArray.java:1734)
    at org.jruby.RubyArray$INVOKER$i$0$0$each.call(RubyArray$INVOKER$i$0$0$each.gen)
    at org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroBlock.call(JavaMethod.java:498)
    at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:77)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:83)
    at org.jruby.ir.instructions.CallBase.interpret(CallBase.java:428)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:355)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.call(IRBlockBody.java:73)
    at org.jruby.runtime.Block.call(Block.java:124)
    at org.jruby.RubyProc.call(RubyProc.java:289)
    at org.jruby.RubyProc.call19(RubyProc.java:273)
    at org.jruby.RubyProc$INVOKER$i$0$0$call19.call(RubyProc$INVOKER$i$0$0$call19.gen)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:204)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:161)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:314)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.call(IRBlockBody.java:73)
    at org.jruby.runtime.Block.call(Block.java:124)
    at org.jruby.RubyProc.call(RubyProc.java:289)
    at org.jruby.internal.runtime.methods.ProcMethod.call(ProcMethod.java:63)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:204)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at java.lang.invoke.LambdaForm$DMH/699780352.invokeVirtual_L6_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/2619171.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/19717364.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.pipeline.RUBY$method$filter_batch$0(/home/logstash/logstash/logstash-core/lib/logstash/pipeline.rb:501)
    at java.lang.invoke.LambdaForm$DMH/614360729.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$MH/770189387.invokeExact_MT(LambdaForm$MH)
    at org.jruby.internal.runtime.methods.CompiledIRMethod.call(CompiledIRMethod.java:103)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.call(MixedModeIRMethod.java:163)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:161)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:314)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.InterpreterEngine.interpret(InterpreterEngine.java:89)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.INTERPRET_METHOD(MixedModeIRMethod.java:214)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.call(MixedModeIRMethod.java:200)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:208)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:193)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:323)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.call(IRBlockBody.java:73)
    at org.jruby.runtime.Block.call(Block.java:124)
    at org.jruby.RubyProc.call(RubyProc.java:289)
    at org.jruby.RubyProc.call(RubyProc.java:246)
    at org.jruby.internal.runtime.RubyRunnable.run(RubyRunnable.java:104)
    at java.lang.Thread.run(Thread.java:748)

"[main-pipeline]>worker14" #57 daemon prio=5 os_prio=0 tid=0x00007fed8005d800 nid=0x10a5 waiting for monitor entry [0x00007fed4fbfb000]
   java.lang.Thread.State: BLOCKED (on object monitor)
    at org.jruby.RubyModule.getMethodsForWrite(RubyModule.java:455)
    - waiting to lock <0x00000006d4d27700> (a org.jruby.RubyClass)
    at org.jruby.RubyModule.addMethodAtBootTimeOnly(RubyModule.java:1212)
    at org.jruby.gen.org$jruby$RubyBoolean$True$POPULATOR.populate(org$jruby$RubyBoolean$True$POPULATOR.java:33)
    at org.jruby.RubyModule.defineAnnotatedMethodsIndividually(RubyModule.java:1060)
    at org.jruby.RubyModule.defineAnnotatedMethods(RubyModule.java:947)
    at org.jruby.RubyBoolean.createTrueClass(RubyBoolean.java:121)
    at org.logstash.ext.JrubyEventExtLibrary$RubyEvent.ruby_cancel(JrubyEventExtLibrary.java:141)
    at java.lang.invoke.LambdaForm$DMH/1554547125.invokeSpecial_LL_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/550752602.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1247233941.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1370651081.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1247233941.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1370651081.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/670971910.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.vendor.bundle.jruby.$2_dot_3_dot_0.gems.logstash_minus_filter_minus_drop_minus_3_dot_0_dot_4.lib.logstash.filters.drop.RUBY$method$filter$0(/home/logstash/logstash/vendor/bundle/jruby/2.3.0/gems/logstash-filter-drop-3.0.4/lib/logstash/filters/drop.rb:42)
    at java.lang.invoke.LambdaForm$DMH/1706377736.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/486715174.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1885996206.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filters.base.RUBY$method$do_filter$0(/home/logstash/logstash/logstash-core/lib/logstash/filters/base.rb:145)
    at java.lang.invoke.LambdaForm$DMH/1706377736.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/486715174.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/2061475679.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/345281752.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1885996206.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filters.base.RUBY$block$multi_filter$1(/home/logstash/logstash/logstash-core/lib/logstash/filters/base.rb:164)
    at java.lang.invoke.LambdaForm$DMH/1614468244.invokeStatic_L8_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$MH/1970881185.invokeExact_MT(LambdaForm$MH)
    at org.jruby.runtime.CompiledIRBlockBody.yieldDirect(CompiledIRBlockBody.java:156)
    at org.jruby.runtime.BlockBody.yield(BlockBody.java:114)
    at org.jruby.runtime.Block.yield(Block.java:165)
    at org.jruby.RubyArray.each(RubyArray.java:1734)
    at java.lang.invoke.LambdaForm$DMH/140799417.invokeVirtual_L3_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/2092769598.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/19717364.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filters.base.RUBY$method$multi_filter$0(/home/logstash/logstash/logstash-core/lib/logstash/filters/base.rb:161)
    at java.lang.invoke.LambdaForm$DMH/1706377736.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/2043318969.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/19717364.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.filter_delegator.RUBY$method$multi_filter$0(/home/logstash/logstash/logstash-core/lib/logstash/filter_delegator.rb:48)
    at java.lang.invoke.LambdaForm$DMH/1269181528.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$MH/770189387.invokeExact_MT(LambdaForm$MH)
    at org.jruby.internal.runtime.methods.CompiledIRMethod.call(CompiledIRMethod.java:103)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.call(MixedModeIRMethod.java:163)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:161)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:314)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.doYield(IRBlockBody.java:186)
    at org.jruby.runtime.BlockBody.yield(BlockBody.java:116)
    at org.jruby.runtime.Block.yield(Block.java:165)
    at org.jruby.RubyArray.each(RubyArray.java:1734)
    at org.jruby.RubyArray$INVOKER$i$0$0$each.call(RubyArray$INVOKER$i$0$0$each.gen)
    at org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroBlock.call(JavaMethod.java:498)
    at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:77)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:83)
    at org.jruby.ir.instructions.CallBase.interpret(CallBase.java:428)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:355)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.call(IRBlockBody.java:73)
    at org.jruby.runtime.Block.call(Block.java:124)
    at org.jruby.RubyProc.call(RubyProc.java:289)
    at org.jruby.RubyProc.call19(RubyProc.java:273)
    at org.jruby.RubyProc$INVOKER$i$0$0$call19.call(RubyProc$INVOKER$i$0$0$call19.gen)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:204)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:161)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:314)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.call(IRBlockBody.java:73)
    at org.jruby.runtime.Block.call(Block.java:124)
    at org.jruby.RubyProc.call(RubyProc.java:289)
    at org.jruby.internal.runtime.methods.ProcMethod.call(ProcMethod.java:63)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:204)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at java.lang.invoke.LambdaForm$DMH/699780352.invokeVirtual_L6_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$BMH/2619171.reinvoke(LambdaForm$BMH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/1067040082.delegate(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/640363654.guard(LambdaForm$MH)
    at java.lang.invoke.LambdaForm$MH/19717364.linkToCallSite(LambdaForm$MH)
    at home.logstash.logstash.logstash_minus_core.lib.logstash.pipeline.RUBY$method$filter_batch$0(/home/logstash/logstash/logstash-core/lib/logstash/pipeline.rb:501)
    at java.lang.invoke.LambdaForm$DMH/614360729.invokeStatic_L7_L(LambdaForm$DMH)
    at java.lang.invoke.LambdaForm$MH/770189387.invokeExact_MT(LambdaForm$MH)
    at org.jruby.internal.runtime.methods.CompiledIRMethod.call(CompiledIRMethod.java:103)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.call(MixedModeIRMethod.java:163)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:161)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:314)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.InterpreterEngine.interpret(InterpreterEngine.java:89)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.INTERPRET_METHOD(MixedModeIRMethod.java:214)
    at org.jruby.internal.runtime.methods.MixedModeIRMethod.call(MixedModeIRMethod.java:200)
    at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:208)
    at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:193)
    at org.jruby.ir.interpreter.InterpreterEngine.processCall(InterpreterEngine.java:323)
    at org.jruby.ir.interpreter.StartupInterpreterEngine.interpret(StartupInterpreterEngine.java:73)
    at org.jruby.ir.interpreter.Interpreter.INTERPRET_BLOCK(Interpreter.java:132)
    at org.jruby.runtime.MixedModeIRBlockBody.commonYieldPath(MixedModeIRBlockBody.java:148)
    at org.jruby.runtime.IRBlockBody.call(IRBlockBody.java:73)
    at org.jruby.runtime.Block.call(Block.java:124)
    at org.jruby.RubyProc.call(RubyProc.java:289)
    at org.jruby.RubyProc.call(RubyProc.java:246)
    at org.jruby.internal.runtime.RubyRunnable.run(RubyRunnable.java:104)
    at java.lang.Thread.run(Thread.java:748)

我可以提高我的表现吗?

标签: multithreadinglogstash

解决方案


推荐阅读