Regression
org.reactivestreams.tck.PublisherVerification.stochastic_spec103_mustSignalOnMethodsSequentially (from Surefire test)
Failing for the past 1 build
(Since Failed
)
Error Message
Illegal concurrent access detected (entering critical section)! Thread[pool-88-thread-1,5,main] emited onNext(SubscriptionHasNextPage [type=thing-search.subscription.events:next, subscriptionId=4ceb25dc-0151-45ed-b271-40f36d1537a5, dittoHeaders=ImmutableDittoHeaders [{correlation-id=efa917cd-dbcf-47cc-a3cc-a24b3768be37, content-type=application/json}], items=[{"thingId":"x:0"}]]) signal, before Thread[mock-provider-1,5,main] finished its onSubscribe() signal.
Stacktrace
java.lang.AssertionError: Illegal concurrent access detected (entering critical section)! Thread[pool-88-thread-1,5,main] emited onNext(SubscriptionHasNextPage [type=thing-search.subscription.events:next, subscriptionId=4ceb25dc-0151-45ed-b271-40f36d1537a5, dittoHeaders=ImmutableDittoHeaders [{correlation-id=efa917cd-dbcf-47cc-a3cc-a24b3768be37, content-type=application/json}], items=[{"thingId":"x:0"}]]) signal, before Thread[mock-provider-1,5,main] finished its onSubscribe() signal. at org.reactivestreams.tck.TestEnvironment.flop(TestEnvironment.java:229) at org.reactivestreams.tck.PublisherVerification$5$1$1$ConcurrentAccessBarrier.enterSignal(PublisherVerification.java:284) at org.reactivestreams.tck.PublisherVerification$5$1$1.onNext(PublisherVerification.java:317) at org.eclipse.ditto.client.streaming.ThingSearchSubscription.handleAdaptable(ThingSearchSubscription.java:186) at org.eclipse.ditto.client.streaming.ThingSearchSubscription.lambda$onNext$2(ThingSearchSubscription.java:158) at org.eclipse.ditto.client.streaming.ThingSearchSubscription.singleThreaded(ThingSearchSubscription.java:132) at org.eclipse.ditto.client.streaming.ThingSearchSubscription.onNext(ThingSearchSubscription.java:156) at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.lambda$withTermination$4(DefaultAdaptableBus.java:214) at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.runConsumerAsync(DefaultAdaptableBus.java:258) at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.publishToPersistentAdaptableSubscribers(DefaultAdaptableBus.java:283) at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.doPublish(DefaultAdaptableBus.java:191) at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.publish(DefaultAdaptableBus.java:161) at org.eclipse.ditto.client.streaming.ThingSearchPublisherVerificationTest.reply(ThingSearchPublisherVerificationTest.java:154) at org.eclipse.ditto.client.streaming.ThingSearchPublisherVerificationTest.lambda$mockSearchBackEnd$0(ThingSearchPublisherVerificationTest.java:100) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) ... Removed 1 stack frames