O2-Czech-Republic / proxima-platform

The Proxima platform.
Apache License 2.0
18 stars 7 forks source link

Optimize ZKGlobalWatermarkTracker #293

Closed je-ik closed 1 year ago

je-ik commented 1 year ago

Most of RUNNABLE threads blocked at

   java.lang.Thread.State: RUNNABLE
        at java.util.stream.ReferencePipeline$3$1.accept(java.base@11.0.15/ReferencePipeline.java:195)
        at java.util.HashMap$ValueSpliterator.forEachRemaining(java.base@11.0.15/HashMap.java:1693)
        at java.util.stream.AbstractPipeline.copyInto(java.base@11.0.15/AbstractPipeline.java:484)
        at java.util.stream.AbstractPipeline.wrapAndCopyInto(java.base@11.0.15/AbstractPipeline.java:474)
        at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(java.base@11.0.15/ReduceOps.java:913)
        at java.util.stream.AbstractPipeline.evaluate(java.base@11.0.15/AbstractPipeline.java:234)
        at java.util.stream.ReferencePipeline.reduce(java.base@11.0.15/ReferencePipeline.java:558)
        at java.util.stream.ReferencePipeline.min(java.base@11.0.15/ReferencePipeline.java:599)
        at cz.o2.proxima.utils.zookeeper.ZKGlobalWatermarkTracker.handleWatchOnChildNode(ZKGlobalWatermarkTracker.java:637)
je-ik commented 1 year ago

Closed via datadrivencz#734