Skip to content

Instantly share code, notes, and snippets.

@wmedvede

wmedvede/gist:4d4640d3793787cf15c49b6046a0969c

Created December 17, 2021 16:51
Show Gist options
  • Save wmedvede/4d4640d3793787cf15c49b6046a0969c to your computer and use it in GitHub Desktop.
Save wmedvede/4d4640d3793787cf15c49b6046a0969c to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
2021-12-17 17:49:33,111 WARN [io.ver.cor.imp.BlockedThreadChecker] (vertx-blocked-thread-checker) Thread Thread[vert.x-eventloop-thread-1,5,main] has been blocked for 2175 ms, time limit is 2000 ms: io.vertx.core.VertxException: Thread blocked
at java.base@11.0.1/jdk.internal.misc.Unsafe.park(Native Method)
at java.base@11.0.1/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234)
at java.base@11.0.1/java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1798)
at java.base@11.0.1/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1868)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.getResultFromFuture(PostgreProcessInstances.java:226)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findByIdInternal(PostgreProcessInstances.java:238)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findById(PostgreProcessInstances.java:120)
at org.kie.kogito.process.ProcessInstances.findById(ProcessInstances.java:24)
at org.kie.kogito.event.impl.CloudEventConsumer.consume(CloudEventConsumer.java:66)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consume(AbstractMessageConsumer.java:102)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consumeCloud(AbstractMessageConsumer.java:93)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer$$Lambda$434/0x000000080049ec40.apply(Unknown Source)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.lambda$produce$1(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver$$Lambda$1048/0x0000000800750040.apply(Unknown Source)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:45)
at org.kie.kogito.app.Query_response_eventsEventReceiver.onEvent(Query_response_eventsEventReceiver.java:33)
at org.kie.kogito.app.Query_response_eventsEventReceiver_ClientProxy.onEvent(Unknown Source)
at org.kie.kogito.app.Query_response_eventsEventReceiver_SmallRyeMessagingInvoker_onEvent_767963bef278f2970bf32edb4ba385196aa18167.invoke(Unknown Source)
at io.smallrye.reactive.messaging.AbstractMediator.invoke(AbstractMediator.java:88)
at io.smallrye.reactive.messaging.SubscriberMediator.lambda$processMethodReturningACompletionStage$18(SubscriberMediator.java:216)
at io.smallrye.reactive.messaging.SubscriberMediator$$Lambda$1045/0x000000080073c040.get(Unknown Source)
at io.smallrye.context.impl.wrappers.SlowContextualSupplier.get(SlowContextualSupplier.java:21)
at io.smallrye.mutiny.operators.uni.builders.UniCreateFromCompletionStage.subscribe(UniCreateFromCompletionStage.java:24)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.operators.uni.UniOnItemOrFailureFlatMap.subscribe(UniOnItemOrFailureFlatMap.java:27)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.request(UniToMultiPublisher.java:63)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onSubscribe(MultiFlatMapOp.java:591)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher.subscribe(UniToMultiPublisher.java:24)
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:156)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.onItem(MultiFlatMapOp.java:191)
at io.smallrye.mutiny.operators.multi.MultiMapOp$MapProcessor.onItem(MultiMapOp.java:50)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.helpers.HalfSerializer.onNext(HalfSerializer.java:31)
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onItem(StrictMultiSubscriber.java:83)
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onItem(MultiOperatorProcessor.java:89)
at io.smallrye.mutiny.operators.multi.MultiOnItemInvoke$MultiOnItemInvokeProcessor.onItem(MultiOnItemInvoke.java:41)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.tryEmit(MultiFlatMapOp.java:228)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onItem(MultiFlatMapOp.java:597)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.onItem(UniToMultiPublisher.java:82)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemConsume$UniOnItemComsumeProcessor.onItem(UniOnItemConsume.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor.lambda$onItem$0(UniEmitOn.java:34)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor$$Lambda$1042/0x000000080073d440.run(Unknown Source)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit.lambda$received$6(KafkaThrottledLatestProcessedCommit.java:199)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit$$Lambda$1043/0x000000080073c840.handle(Unknown Source)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:100)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:63)
at io.vertx.core.impl.EventLoopContext.lambda$runOnContext$0(EventLoopContext.java:38)
at io.vertx.core.impl.EventLoopContext$$Lambda$811/0x000000080061e040.run(Unknown Source)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base@11.0.1/java.lang.Thread.run(Thread.java:834)
2021-12-17 17:49:35,111 WARN [io.ver.cor.imp.BlockedThreadChecker] (vertx-blocked-thread-checker) Thread Thread[vert.x-eventloop-thread-1,5,main] has been blocked for 4175 ms, time limit is 2000 ms: io.vertx.core.VertxException: Thread blocked
at java.base@11.0.1/jdk.internal.misc.Unsafe.park(Native Method)
at java.base@11.0.1/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234)
at java.base@11.0.1/java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1798)
at java.base@11.0.1/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1868)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.getResultFromFuture(PostgreProcessInstances.java:226)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findByIdInternal(PostgreProcessInstances.java:238)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findById(PostgreProcessInstances.java:120)
at org.kie.kogito.process.ProcessInstances.findById(ProcessInstances.java:24)
at org.kie.kogito.event.impl.CloudEventConsumer.consume(CloudEventConsumer.java:66)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consume(AbstractMessageConsumer.java:102)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consumeCloud(AbstractMessageConsumer.java:93)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer$$Lambda$434/0x000000080049ec40.apply(Unknown Source)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.lambda$produce$1(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver$$Lambda$1048/0x0000000800750040.apply(Unknown Source)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:45)
at org.kie.kogito.app.Query_response_eventsEventReceiver.onEvent(Query_response_eventsEventReceiver.java:33)
at org.kie.kogito.app.Query_response_eventsEventReceiver_ClientProxy.onEvent(Unknown Source)
at org.kie.kogito.app.Query_response_eventsEventReceiver_SmallRyeMessagingInvoker_onEvent_767963bef278f2970bf32edb4ba385196aa18167.invoke(Unknown Source)
at io.smallrye.reactive.messaging.AbstractMediator.invoke(AbstractMediator.java:88)
at io.smallrye.reactive.messaging.SubscriberMediator.lambda$processMethodReturningACompletionStage$18(SubscriberMediator.java:216)
at io.smallrye.reactive.messaging.SubscriberMediator$$Lambda$1045/0x000000080073c040.get(Unknown Source)
at io.smallrye.context.impl.wrappers.SlowContextualSupplier.get(SlowContextualSupplier.java:21)
at io.smallrye.mutiny.operators.uni.builders.UniCreateFromCompletionStage.subscribe(UniCreateFromCompletionStage.java:24)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.operators.uni.UniOnItemOrFailureFlatMap.subscribe(UniOnItemOrFailureFlatMap.java:27)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.request(UniToMultiPublisher.java:63)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onSubscribe(MultiFlatMapOp.java:591)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher.subscribe(UniToMultiPublisher.java:24)
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:156)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.onItem(MultiFlatMapOp.java:191)
at io.smallrye.mutiny.operators.multi.MultiMapOp$MapProcessor.onItem(MultiMapOp.java:50)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.helpers.HalfSerializer.onNext(HalfSerializer.java:31)
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onItem(StrictMultiSubscriber.java:83)
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onItem(MultiOperatorProcessor.java:89)
at io.smallrye.mutiny.operators.multi.MultiOnItemInvoke$MultiOnItemInvokeProcessor.onItem(MultiOnItemInvoke.java:41)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.tryEmit(MultiFlatMapOp.java:228)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onItem(MultiFlatMapOp.java:597)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.onItem(UniToMultiPublisher.java:82)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemConsume$UniOnItemComsumeProcessor.onItem(UniOnItemConsume.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor.lambda$onItem$0(UniEmitOn.java:34)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor$$Lambda$1042/0x000000080073d440.run(Unknown Source)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit.lambda$received$6(KafkaThrottledLatestProcessedCommit.java:199)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit$$Lambda$1043/0x000000080073c840.handle(Unknown Source)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:100)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:63)
at io.vertx.core.impl.EventLoopContext.lambda$runOnContext$0(EventLoopContext.java:38)
at io.vertx.core.impl.EventLoopContext$$Lambda$811/0x000000080061e040.run(Unknown Source)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base@11.0.1/java.lang.Thread.run(Thread.java:834)
2021-12-17 17:49:37,111 WARN [io.ver.cor.imp.BlockedThreadChecker] (vertx-blocked-thread-checker) Thread Thread[vert.x-eventloop-thread-1,5,main] has been blocked for 6175 ms, time limit is 2000 ms: io.vertx.core.VertxException: Thread blocked
at java.base@11.0.1/jdk.internal.misc.Unsafe.park(Native Method)
at java.base@11.0.1/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234)
at java.base@11.0.1/java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1798)
at java.base@11.0.1/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1868)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.getResultFromFuture(PostgreProcessInstances.java:226)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findByIdInternal(PostgreProcessInstances.java:238)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findById(PostgreProcessInstances.java:120)
at org.kie.kogito.process.ProcessInstances.findById(ProcessInstances.java:24)
at org.kie.kogito.event.impl.CloudEventConsumer.consume(CloudEventConsumer.java:66)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consume(AbstractMessageConsumer.java:102)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consumeCloud(AbstractMessageConsumer.java:93)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer$$Lambda$434/0x000000080049ec40.apply(Unknown Source)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.lambda$produce$1(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver$$Lambda$1048/0x0000000800750040.apply(Unknown Source)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:45)
at org.kie.kogito.app.Query_response_eventsEventReceiver.onEvent(Query_response_eventsEventReceiver.java:33)
at org.kie.kogito.app.Query_response_eventsEventReceiver_ClientProxy.onEvent(Unknown Source)
at org.kie.kogito.app.Query_response_eventsEventReceiver_SmallRyeMessagingInvoker_onEvent_767963bef278f2970bf32edb4ba385196aa18167.invoke(Unknown Source)
at io.smallrye.reactive.messaging.AbstractMediator.invoke(AbstractMediator.java:88)
at io.smallrye.reactive.messaging.SubscriberMediator.lambda$processMethodReturningACompletionStage$18(SubscriberMediator.java:216)
at io.smallrye.reactive.messaging.SubscriberMediator$$Lambda$1045/0x000000080073c040.get(Unknown Source)
at io.smallrye.context.impl.wrappers.SlowContextualSupplier.get(SlowContextualSupplier.java:21)
at io.smallrye.mutiny.operators.uni.builders.UniCreateFromCompletionStage.subscribe(UniCreateFromCompletionStage.java:24)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.operators.uni.UniOnItemOrFailureFlatMap.subscribe(UniOnItemOrFailureFlatMap.java:27)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.request(UniToMultiPublisher.java:63)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onSubscribe(MultiFlatMapOp.java:591)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher.subscribe(UniToMultiPublisher.java:24)
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:156)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.onItem(MultiFlatMapOp.java:191)
at io.smallrye.mutiny.operators.multi.MultiMapOp$MapProcessor.onItem(MultiMapOp.java:50)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.helpers.HalfSerializer.onNext(HalfSerializer.java:31)
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onItem(StrictMultiSubscriber.java:83)
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onItem(MultiOperatorProcessor.java:89)
at io.smallrye.mutiny.operators.multi.MultiOnItemInvoke$MultiOnItemInvokeProcessor.onItem(MultiOnItemInvoke.java:41)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.tryEmit(MultiFlatMapOp.java:228)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onItem(MultiFlatMapOp.java:597)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.onItem(UniToMultiPublisher.java:82)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemConsume$UniOnItemComsumeProcessor.onItem(UniOnItemConsume.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor.lambda$onItem$0(UniEmitOn.java:34)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor$$Lambda$1042/0x000000080073d440.run(Unknown Source)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit.lambda$received$6(KafkaThrottledLatestProcessedCommit.java:199)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit$$Lambda$1043/0x000000080073c840.handle(Unknown Source)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:100)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:63)
at io.vertx.core.impl.EventLoopContext.lambda$runOnContext$0(EventLoopContext.java:38)
at io.vertx.core.impl.EventLoopContext$$Lambda$811/0x000000080061e040.run(Unknown Source)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base@11.0.1/java.lang.Thread.run(Thread.java:834)
2021-12-17 17:49:39,112 WARN [io.ver.cor.imp.BlockedThreadChecker] (vertx-blocked-thread-checker) Thread Thread[vert.x-eventloop-thread-1,5,main] has been blocked for 8176 ms, time limit is 2000 ms: io.vertx.core.VertxException: Thread blocked
at java.base@11.0.1/jdk.internal.misc.Unsafe.park(Native Method)
at java.base@11.0.1/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234)
at java.base@11.0.1/java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1798)
at java.base@11.0.1/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1868)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.getResultFromFuture(PostgreProcessInstances.java:226)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findByIdInternal(PostgreProcessInstances.java:238)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findById(PostgreProcessInstances.java:120)
at org.kie.kogito.process.ProcessInstances.findById(ProcessInstances.java:24)
at org.kie.kogito.event.impl.CloudEventConsumer.consume(CloudEventConsumer.java:66)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consume(AbstractMessageConsumer.java:102)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consumeCloud(AbstractMessageConsumer.java:93)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer$$Lambda$434/0x000000080049ec40.apply(Unknown Source)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.lambda$produce$1(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver$$Lambda$1048/0x0000000800750040.apply(Unknown Source)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235)
at java.base@11.0.1/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:45)
at org.kie.kogito.app.Query_response_eventsEventReceiver.onEvent(Query_response_eventsEventReceiver.java:33)
at org.kie.kogito.app.Query_response_eventsEventReceiver_ClientProxy.onEvent(Unknown Source)
at org.kie.kogito.app.Query_response_eventsEventReceiver_SmallRyeMessagingInvoker_onEvent_767963bef278f2970bf32edb4ba385196aa18167.invoke(Unknown Source)
at io.smallrye.reactive.messaging.AbstractMediator.invoke(AbstractMediator.java:88)
at io.smallrye.reactive.messaging.SubscriberMediator.lambda$processMethodReturningACompletionStage$18(SubscriberMediator.java:216)
at io.smallrye.reactive.messaging.SubscriberMediator$$Lambda$1045/0x000000080073c040.get(Unknown Source)
at io.smallrye.context.impl.wrappers.SlowContextualSupplier.get(SlowContextualSupplier.java:21)
at io.smallrye.mutiny.operators.uni.builders.UniCreateFromCompletionStage.subscribe(UniCreateFromCompletionStage.java:24)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.operators.uni.UniOnItemOrFailureFlatMap.subscribe(UniOnItemOrFailureFlatMap.java:27)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.request(UniToMultiPublisher.java:63)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onSubscribe(MultiFlatMapOp.java:591)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher.subscribe(UniToMultiPublisher.java:24)
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:156)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.onItem(MultiFlatMapOp.java:191)
at io.smallrye.mutiny.operators.multi.MultiMapOp$MapProcessor.onItem(MultiMapOp.java:50)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.helpers.HalfSerializer.onNext(HalfSerializer.java:31)
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onItem(StrictMultiSubscriber.java:83)
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onItem(MultiOperatorProcessor.java:89)
at io.smallrye.mutiny.operators.multi.MultiOnItemInvoke$MultiOnItemInvokeProcessor.onItem(MultiOnItemInvoke.java:41)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.tryEmit(MultiFlatMapOp.java:228)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onItem(MultiFlatMapOp.java:597)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.onItem(UniToMultiPublisher.java:82)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemConsume$UniOnItemComsumeProcessor.onItem(UniOnItemConsume.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor.lambda$onItem$0(UniEmitOn.java:34)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor$$Lambda$1042/0x000000080073d440.run(Unknown Source)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit.lambda$received$6(KafkaThrottledLatestProcessedCommit.java:199)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit$$Lambda$1043/0x000000080073c840.handle(Unknown Source)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:100)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:63)
at io.vertx.core.impl.EventLoopContext.lambda$runOnContext$0(EventLoopContext.java:38)
at io.vertx.core.impl.EventLoopContext$$Lambda$811/0x000000080061e040.run(Unknown Source)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base@11.0.1/java.lang.Thread.run(Thread.java:834)
2021-12-17 17:49:40,959 ERROR [org.kie.kog.add.qua.mes.com.AbstractQuarkusCloudEventReceiver] (vert.x-eventloop-thread-1) Error processing message {"specversion":"1.0","id":"81edcb44-a06b-41a6-8530-c223973e1d5a","source":"","type":"query_response_events","time":"2021-12-17T17:49:29.81922+01:00","kogitoprocrefid":"2ea5bc57-e30e-47fd-91a7-6276800458ec","data":{"answer":"Response1"}}: java.util.concurrent.CompletionException: java.lang.RuntimeException: Error finding process instance 2ea5bc57-e30e-47fd-91a7-6276800458ec
at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314)
at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1113)
at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235)
at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:61)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.produce(AbstractQuarkusCloudEventReceiver.java:45)
at org.kie.kogito.app.Query_response_eventsEventReceiver.onEvent(Query_response_eventsEventReceiver.java:33)
at org.kie.kogito.app.Query_response_eventsEventReceiver_ClientProxy.onEvent(Unknown Source)
at org.kie.kogito.app.Query_response_eventsEventReceiver_SmallRyeMessagingInvoker_onEvent_767963bef278f2970bf32edb4ba385196aa18167.invoke(Unknown Source)
at io.smallrye.reactive.messaging.AbstractMediator.invoke(AbstractMediator.java:88)
at io.smallrye.reactive.messaging.SubscriberMediator.lambda$processMethodReturningACompletionStage$18(SubscriberMediator.java:216)
at io.smallrye.context.impl.wrappers.SlowContextualSupplier.get(SlowContextualSupplier.java:21)
at io.smallrye.mutiny.operators.uni.builders.UniCreateFromCompletionStage.subscribe(UniCreateFromCompletionStage.java:24)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.operators.uni.UniOnItemOrFailureFlatMap.subscribe(UniOnItemOrFailureFlatMap.java:27)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.request(UniToMultiPublisher.java:63)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onSubscribe(MultiFlatMapOp.java:591)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher.subscribe(UniToMultiPublisher.java:24)
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:156)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.onItem(MultiFlatMapOp.java:191)
at io.smallrye.mutiny.operators.multi.MultiMapOp$MapProcessor.onItem(MultiMapOp.java:50)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.subscription.SafeSubscriber.onNext(SafeSubscriber.java:98)
at io.smallrye.mutiny.helpers.HalfSerializer.onNext(HalfSerializer.java:31)
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onItem(StrictMultiSubscriber.java:83)
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onItem(MultiOperatorProcessor.java:89)
at io.smallrye.mutiny.operators.multi.MultiOnItemInvoke$MultiOnItemInvokeProcessor.onItem(MultiOnItemInvoke.java:41)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber.tryEmit(MultiFlatMapOp.java:228)
at io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapInner.onItem(MultiFlatMapOp.java:597)
at io.smallrye.mutiny.subscription.MultiSubscriber.onNext(MultiSubscriber.java:61)
at io.smallrye.mutiny.converters.uni.UniToMultiPublisher$UniToMultiSubscription.onItem(UniToMultiPublisher.java:82)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemConsume$UniOnItemComsumeProcessor.onItem(UniOnItemConsume.java:43)
at io.smallrye.mutiny.operators.uni.UniOnItemTransform$UniOnItemTransformProcessor.onItem(UniOnItemTransform.java:43)
at io.smallrye.mutiny.operators.uni.UniEmitOn$UniEmitOnProcessor.lambda$onItem$0(UniEmitOn.java:34)
at io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit.lambda$received$6(KafkaThrottledLatestProcessedCommit.java:199)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:100)
at io.vertx.core.impl.AbstractContext.dispatch(AbstractContext.java:63)
at io.vertx.core.impl.EventLoopContext.lambda$runOnContext$0(EventLoopContext.java:38)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.lang.RuntimeException: Error finding process instance 2ea5bc57-e30e-47fd-91a7-6276800458ec
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.uncheckedException(PostgreProcessInstances.java:177)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findByIdInternal(PostgreProcessInstances.java:243)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findById(PostgreProcessInstances.java:120)
at org.kie.kogito.process.ProcessInstances.findById(ProcessInstances.java:24)
at org.kie.kogito.event.impl.CloudEventConsumer.consume(CloudEventConsumer.java:66)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consume(AbstractMessageConsumer.java:102)
at org.kie.kogito.services.event.impl.AbstractMessageConsumer.consumeCloud(AbstractMessageConsumer.java:93)
at org.kie.kogito.addon.quarkus.messaging.common.AbstractQuarkusCloudEventReceiver.lambda$produce$1(AbstractQuarkusCloudEventReceiver.java:61)
at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106)
... 47 more
Caused by: java.util.concurrent.TimeoutException
at java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.getResultFromFuture(PostgreProcessInstances.java:226)
at org.kie.kogito.persistence.postgresql.PostgreProcessInstances.findByIdInternal(PostgreProcessInstances.java:238)
... 54 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment