ClientClosureRaceTest.testPipelinedPosts test failure

Open

#659 opened on Jun 28, 2019 8 comments 0 reactions 0 assignees View on GitHub

flaky tests

Dominant language: Java
Stars: 1k
Forks: 229
Avg merge: 23h 23m
Merged PRs (30d): 16

Description

https://ci.servicetalk.io/job/servicetalk-java11-prb/379/testReport/junit/io.servicetalk.http.netty/ClientClosureRaceTest/testPipelinedPosts/

```
Error Message

java.util.concurrent.ExecutionException: io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown
Stacktrace

java.util.concurrent.ExecutionException: io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown
at io.servicetalk.concurrent.api.SourceToFuture.reportGet(SourceToFuture.java:121)
at io.servicetalk.concurrent.api.SourceToFuture.get(SourceToFuture.java:92)
at io.servicetalk.http.netty.ClientClosureRaceTest.runIterations(ClientClosureRaceTest.java:148)
at io.servicetalk.http.netty.ClientClosureRaceTest.testPipelinedPosts(ClientClosureRaceTest.java:137)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at io.servicetalk.concurrent.internal.ServiceTalkTestTimeout$TimeoutStatement$CallableStatement.call(ServiceTalkTestTimeout.java:171)
at io.servicetalk.concurrent.internal.ServiceTalkTestTimeout$TimeoutStatement$CallableStatement.call(ServiceTalkTestTimeout.java:163)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown
at io.netty.channel.AbstractChannel$AbstractUnsafe.shutdownOutput(AbstractChannel.java:646)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:954)
at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.flush0(AbstractEpollChannel.java:517)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:906)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1370)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:749)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:741)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:727)
at io.netty.channel.DefaultChannelPipeline.flush(DefaultChannelPipeline.java:978)
at io.netty.channel.AbstractChannel.flush(AbstractChannel.java:253)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.lambda$new$0(Flush.java:68)
at io.servicetalk.transport.netty.internal.FlushOnEnd$1.writeTerminated(FlushOnEnd.java:31)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:125)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.api.CancellableThenSubscription.setSubscription(CancellableThenSubscription.java:108)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSubscribe(SingleFlatMapPublisher.java:75)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.FromArrayPublisher.doSubscribe(FromArrayPublisher.java:45)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36)
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68)
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435)
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSuccess(SingleFlatMapPublisher.java:95)
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onComplete(ReduceSingle.java:114)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.FilterPublisher$1.onComplete(FilterPublisher.java:72)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.internal.ScalarValueSubscription.request(ScalarValueSubscription.java:71)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onSubscribe(ReduceSingle.java:97)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41)
at io.servicetalk.concurrent.api.FilterPublisher$1.onSubscribe(FilterPublisher.java:49)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.FromSingleItemPublisher.doSubscribe(FromSingleItemPublisher.java:38)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.ReduceSingle.handleSubscribe(ReduceSingle.java:76)
at io.servicetalk.concurrent.api.Single.delegateSubscribe(Single.java:1498)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher.handleSubscribe(SingleFlatMapPublisher.java:44)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48)
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68)
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435)
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206)
at io.servicetalk.concurrent.api.AbstractNoHandleSubscribePublisher.subscribe(AbstractNoHandleSubscribePublisher.java:52)
at io.servicetalk.transport.netty.internal.DefaultNettyConnection$2.handleSubscribe(DefaultNettyConnection.java:313)
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.ResumeCompletable.handleSubscribe(ResumeCompletable.java:44)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46)
at io.servicetalk.concurrent.api.CompletableSubscribeShareContext.handleSubscribe(CompletableSubscribeShareContext.java:34)
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80)
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540)
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137)
at io.servicetalk.concurrent.api.CompletableDefer.handleSubscribe(CompletableDefer.java:47)
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564)
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80)
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540)
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137)
at io.servicetalk.concurrent.api.CompletableDefer.subscribe(CompletableDefer.java:52)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:235)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:222)
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.executeNextTask(SequentialTaskQueue.java:108)
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.postTaskTermination(SequentialTaskQueue.java:84)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.safePostTaskTermination(DefaultNettyPipelinedConnection.java:339)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.onComplete(DefaultNettyPipelinedConnection.java:311)
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41)
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49)
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41)
at io.servicetalk.concurrent.api.AfterFinallyCompletable$AfterFinallyCompletableSubscriber.onComplete(AfterFinallyCompletable.java:60)
at io.servicetalk.concurrent.api.ResumeCompletable$ResumeSubscriber.onComplete(ResumeCompletable.java:83)
at io.servicetalk.concurrent.api.BeforeFinallyCompletable$BeforeFinallyCompletableSubscriber.onComplete(BeforeFinallyCompletable.java:65)
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.terminateSubscriber(WriteStreamSubscriber.java:394)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.sourceTerminated(WriteStreamSubscriber.java:284)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.onComplete(WriteStreamSubscriber.java:179)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:130)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.api.CancellableThenSubscription.request(CancellableThenSubscription.java:62)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber$1.request(Flush.java:86)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.requestMoreIfRequired(WriteStreamSubscriber.java:245)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.lambda$onSubscribe$0(WriteStreamSubscriber.java:126)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:338)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
... 1 more
Caused by: io.netty.channel.unix.Errors$NativeIoException: syscall:writev(..) failed: Broken pipe
at io.netty.channel.unix.FileDescriptor.writeAddresses(..)(Unknown Source)

Standard Output
2019-06-28 03:04:22,252 Time-limited test [INFO ] ClientClosureRaceTest - Completed 141 requests
2019-06-28 03:04:22,429 Time-limited test [INFO ] ClientClosureRaceTest - Completed 121 requests
2019-06-28 03:04:22,436 servicetalk-global-io-executor-2-9 [WARN ] ChannelOutboundBuffer - Failed to mark a promise as failure because it has failed already: WriteStreamSubscriber$AllWritesPromise@4fe094b0(failure: io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown), unnotified cause: io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown
at io.netty.channel.AbstractChannel$AbstractUnsafe.shutdownOutput(AbstractChannel.java:646)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:954)
at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.flush0(AbstractEpollChannel.java:517)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:906)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1370)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:749)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:741)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:727)
at io.netty.channel.DefaultChannelPipeline.flush(DefaultChannelPipeline.java:978)
at io.netty.channel.AbstractChannel.flush(AbstractChannel.java:253)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.lambda$new$0(Flush.java:68)
at io.servicetalk.transport.netty.internal.FlushOnEnd$1.writeTerminated(FlushOnEnd.java:31)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:125)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.api.CancellableThenSubscription.setSubscription(CancellableThenSubscription.java:108)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSubscribe(SingleFlatMapPublisher.java:75)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.FromArrayPublisher.doSubscribe(FromArrayPublisher.java:45)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36)
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68)
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435)
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSuccess(SingleFlatMapPublisher.java:95)
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onComplete(ReduceSingle.java:114)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.FilterPublisher$1.onComplete(FilterPublisher.java:72)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.internal.ScalarValueSubscription.request(ScalarValueSubscription.java:71)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onSubscribe(ReduceSingle.java:97)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41)
at io.servicetalk.concurrent.api.FilterPublisher$1.onSubscribe(FilterPublisher.java:49)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.FromSingleItemPublisher.doSubscribe(FromSingleItemPublisher.java:38)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.ReduceSingle.handleSubscribe(ReduceSingle.java:76)
at io.servicetalk.concurrent.api.Single.delegateSubscribe(Single.java:1498)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher.handleSubscribe(SingleFlatMapPublisher.java:44)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48)
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68)
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435)
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206)
at io.servicetalk.concurrent.api.AbstractNoHandleSubscribePublisher.subscribe(AbstractNoHandleSubscribePublisher.java:52)
at io.servicetalk.transport.netty.internal.DefaultNettyConnection$2.handleSubscribe(DefaultNettyConnection.java:313)
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.ResumeCompletable.handleSubscribe(ResumeCompletable.java:44)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46)
at io.servicetalk.concurrent.api.CompletableSubscribeShareContext.handleSubscribe(CompletableSubscribeShareContext.java:34)
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80)
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540)
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137)
at io.servicetalk.concurrent.api.CompletableDefer.handleSubscribe(CompletableDefer.java:47)
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564)
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80)
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540)
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137)
at io.servicetalk.concurrent.api.CompletableDefer.subscribe(CompletableDefer.java:52)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:235)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:222)
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.executeNextTask(SequentialTaskQueue.java:108)
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.postTaskTermination(SequentialTaskQueue.java:84)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.safePostTaskTermination(DefaultNettyPipelinedConnection.java:339)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.onComplete(DefaultNettyPipelinedConnection.java:311)
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41)
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49)
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41)
at io.servicetalk.concurrent.api.AfterFinallyCompletable$AfterFinallyCompletableSubscriber.onComplete(AfterFinallyCompletable.java:60)
at io.servicetalk.concurrent.api.ResumeCompletable$ResumeSubscriber.onComplete(ResumeCompletable.java:83)
at io.servicetalk.concurrent.api.BeforeFinallyCompletable$BeforeFinallyCompletableSubscriber.onComplete(BeforeFinallyCompletable.java:65)
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.terminateSubscriber(WriteStreamSubscriber.java:394)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.sourceTerminated(WriteStreamSubscriber.java:284)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.onComplete(WriteStreamSubscriber.java:179)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:130)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.api.CancellableThenSubscription.request(CancellableThenSubscription.java:62)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber$1.request(Flush.java:86)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.requestMoreIfRequired(WriteStreamSubscriber.java:245)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.lambda$onSubscribe$0(WriteStreamSubscriber.java:126)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:338)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
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: io.netty.channel.unix.Errors$NativeIoException: syscall:writev(..) failed: Broken pipe
at io.netty.channel.unix.FileDescriptor.writeAddresses(..)(Unknown Source)

io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown
at io.netty.channel.AbstractChannel$AbstractUnsafe.shutdownOutput(AbstractChannel.java:646) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:954) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.flush0(AbstractEpollChannel.java:517) [netty-transport-native-epoll-4.1.36.Final-linux-x86_64.jar:4.1.36.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:906) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1370) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:749) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:741) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:727) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.DefaultChannelPipeline.flush(DefaultChannelPipeline.java:978) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.AbstractChannel.flush(AbstractChannel.java:253) [netty-transport-4.1.36.Final.jar:4.1.36.Final]
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.lambda$new$0(Flush.java:68) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.FlushOnEnd$1.writeTerminated(FlushOnEnd.java:31) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:125) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.CancellableThenSubscription.setSubscription(CancellableThenSubscription.java:108) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSubscribe(SingleFlatMapPublisher.java:75) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FromArrayPublisher.doSubscribe(FromArrayPublisher.java:45) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSuccess(SingleFlatMapPublisher.java:95) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onComplete(ReduceSingle.java:114) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FilterPublisher$1.onComplete(FilterPublisher.java:72) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.internal.ScalarValueSubscription.request(ScalarValueSubscription.java:71) [servicetalk-concurrent-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122) [servicetalk-concurrent-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122) [servicetalk-concurrent-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onSubscribe(ReduceSingle.java:97) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FilterPublisher$1.onSubscribe(FilterPublisher.java:49) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FromSingleItemPublisher.doSubscribe(FromSingleItemPublisher.java:38) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ReduceSingle.handleSubscribe(ReduceSingle.java:76) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Single.delegateSubscribe(Single.java:1498) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.SingleFlatMapPublisher.handleSubscribe(SingleFlatMapPublisher.java:44) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AbstractNoHandleSubscribePublisher.subscribe(AbstractNoHandleSubscribePublisher.java:52) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.DefaultNettyConnection$2.handleSubscribe(DefaultNettyConnection.java:313) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ResumeCompletable.handleSubscribe(ResumeCompletable.java:44) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.CompletableSubscribeShareContext.handleSubscribe(CompletableSubscribeShareContext.java:34) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.CompletableDefer.handleSubscribe(CompletableDefer.java:47) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.CompletableDefer.subscribe(CompletableDefer.java:52) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:235) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:222) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.executeNextTask(SequentialTaskQueue.java:108) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.postTaskTermination(SequentialTaskQueue.java:84) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.safePostTaskTermination(DefaultNettyPipelinedConnection.java:339) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.onComplete(DefaultNettyPipelinedConnection.java:311) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.AfterFinallyCompletable$AfterFinallyCompletableSubscriber.onComplete(AfterFinallyCompletable.java:60) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ResumeCompletable$ResumeSubscriber.onComplete(ResumeCompletable.java:83) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.BeforeFinallyCompletable$BeforeFinallyCompletableSubscriber.onComplete(BeforeFinallyCompletable.java:65) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.terminateSubscriber(WriteStreamSubscriber.java:394) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.sourceTerminated(WriteStreamSubscriber.java:284) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.onComplete(WriteStreamSubscriber.java:179) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:130) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.CancellableThenSubscription.request(CancellableThenSubscription.java:62) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber$1.request(Flush.java:86) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43) [servicetalk-concurrent-api-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122) [servicetalk-concurrent-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.requestMoreIfRequired(WriteStreamSubscriber.java:245) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.lambda$onSubscribe$0(WriteStreamSubscriber.java:126) [servicetalk-transport-netty-internal-0.16.0-SNAPSHOT.jar:0.16.0-SNAPSHOT]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [netty-common-4.1.36.Final.jar:4.1.36.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405) [netty-common-4.1.36.Final.jar:4.1.36.Final]
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:338) [netty-transport-native-epoll-4.1.36.Final-linux-x86_64.jar:4.1.36.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906) [netty-common-4.1.36.Final.jar:4.1.36.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [netty-common-4.1.36.Final.jar:4.1.36.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [netty-common-4.1.36.Final.jar:4.1.36.Final]
at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by: io.netty.channel.unix.Errors$NativeIoException: syscall:writev(..) failed: Broken pipe
at io.netty.channel.unix.FileDescriptor.writeAddresses(..)(Unknown Source) ~[netty-transport-native-unix-common-4.1.36.Final.jar:4.1.36.Final]
2019-06-28 03:04:22,445 servicetalk-global-io-executor-2-9 [WARN ] ChannelOutboundBuffer - Failed to mark a promise as failure because it has failed already: WriteStreamSubscriber$AllWritesPromise@4fe094b0(failure: io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown), unnotified cause: io.netty.channel.socket.ChannelOutputShutdownException: Channel output shutdown
at io.netty.channel.AbstractChannel$AbstractUnsafe.shutdownOutput(AbstractChannel.java:646)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:954)
at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.flush0(AbstractEpollChannel.java:517)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:906)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1370)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:749)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:741)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:727)
at io.netty.channel.DefaultChannelPipeline.flush(DefaultChannelPipeline.java:978)
at io.netty.channel.AbstractChannel.flush(AbstractChannel.java:253)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.lambda$new$0(Flush.java:68)
at io.servicetalk.transport.netty.internal.FlushOnEnd$1.writeTerminated(FlushOnEnd.java:31)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:125)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.api.CancellableThenSubscription.setSubscription(CancellableThenSubscription.java:108)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSubscribe(SingleFlatMapPublisher.java:75)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.FromArrayPublisher.doSubscribe(FromArrayPublisher.java:45)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36)
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68)
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435)
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onSuccess(SingleFlatMapPublisher.java:95)
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onComplete(ReduceSingle.java:114)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.FilterPublisher$1.onComplete(FilterPublisher.java:72)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.internal.ScalarValueSubscription.request(ScalarValueSubscription.java:71)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.concurrent.api.ReduceSingle$ReduceSubscriber.onSubscribe(ReduceSingle.java:97)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onSubscribe(ContextPreservingSubscriptionSubscriber.java:41)
at io.servicetalk.concurrent.api.FilterPublisher$1.onSubscribe(FilterPublisher.java:49)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onSubscribe(ContextPreservingSubscriber.java:38)
at io.servicetalk.concurrent.api.FromSingleItemPublisher.doSubscribe(FromSingleItemPublisher.java:38)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisher.handleSubscribe(AbstractSynchronousPublisher.java:36)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.ReduceSingle.handleSubscribe(ReduceSingle.java:76)
at io.servicetalk.concurrent.api.Single.delegateSubscribe(Single.java:1498)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher.handleSubscribe(SingleFlatMapPublisher.java:44)
at io.servicetalk.concurrent.api.Publisher.delegateSubscribe(Publisher.java:2414)
at io.servicetalk.concurrent.api.AbstractSynchronousPublisherOperator.handleSubscribe(AbstractSynchronousPublisherOperator.java:48)
at io.servicetalk.concurrent.api.Publisher.lambda$subscribeWithContext$10(Publisher.java:2436)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:68)
at io.servicetalk.concurrent.api.Publisher.subscribeWithContext(Publisher.java:2435)
at io.servicetalk.concurrent.api.Publisher.subscribeInternal(Publisher.java:2206)
at io.servicetalk.concurrent.api.AbstractNoHandleSubscribePublisher.subscribe(AbstractNoHandleSubscribePublisher.java:52)
at io.servicetalk.transport.netty.internal.DefaultNettyConnection$2.handleSubscribe(DefaultNettyConnection.java:313)
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.ResumeCompletable.handleSubscribe(ResumeCompletable.java:44)
at io.servicetalk.concurrent.api.Completable.delegateSubscribe(Completable.java:1520)
at io.servicetalk.concurrent.api.AbstractSynchronousCompletableOperator.handleSubscribe(AbstractSynchronousCompletableOperator.java:46)
at io.servicetalk.concurrent.api.CompletableSubscribeShareContext.handleSubscribe(CompletableSubscribeShareContext.java:34)
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80)
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540)
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137)
at io.servicetalk.concurrent.api.CompletableDefer.handleSubscribe(CompletableDefer.java:47)
at io.servicetalk.concurrent.api.Completable.handleSubscribe(Completable.java:1564)
at io.servicetalk.concurrent.api.Completable.lambda$subscribeWithContext$0(Completable.java:1541)
at io.servicetalk.concurrent.api.ContextPreservingConsumer.accept(ContextPreservingConsumer.java:37)
at io.servicetalk.concurrent.api.NoopOffloader.offloadSubscribe(NoopOffloader.java:80)
at io.servicetalk.concurrent.api.Completable.subscribeWithContext(Completable.java:1540)
at io.servicetalk.concurrent.api.Completable.subscribeInternal(Completable.java:1137)
at io.servicetalk.concurrent.api.CompletableDefer.subscribe(CompletableDefer.java:52)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:235)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteQueue.execute(DefaultNettyPipelinedConnection.java:222)
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.executeNextTask(SequentialTaskQueue.java:108)
at io.servicetalk.transport.netty.internal.SequentialTaskQueue.postTaskTermination(SequentialTaskQueue.java:84)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.safePostTaskTermination(DefaultNettyPipelinedConnection.java:339)
at io.servicetalk.transport.netty.internal.DefaultNettyPipelinedConnection$WriteSourceSubscriber.onComplete(DefaultNettyPipelinedConnection.java:311)
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41)
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49)
at io.servicetalk.concurrent.api.ContextPreservingCancellableCompletableSubscriber.onComplete(ContextPreservingCancellableCompletableSubscriber.java:41)
at io.servicetalk.concurrent.api.AfterFinallyCompletable$AfterFinallyCompletableSubscriber.onComplete(AfterFinallyCompletable.java:60)
at io.servicetalk.concurrent.api.ResumeCompletable$ResumeSubscriber.onComplete(ResumeCompletable.java:83)
at io.servicetalk.concurrent.api.BeforeFinallyCompletable$BeforeFinallyCompletableSubscriber.onComplete(BeforeFinallyCompletable.java:65)
at io.servicetalk.concurrent.api.ContextPreservingCompletableSubscriber.onComplete(ContextPreservingCompletableSubscriber.java:49)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.terminateSubscriber(WriteStreamSubscriber.java:394)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber$AllWritesPromise.sourceTerminated(WriteStreamSubscriber.java:284)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.onComplete(WriteStreamSubscriber.java:179)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber.onComplete(Flush.java:130)
at io.servicetalk.concurrent.api.SingleFlatMapPublisher$SubscriberImpl.onComplete(SingleFlatMapPublisher.java:111)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.ContextPreservingSubscriptionSubscriber.onComplete(ContextPreservingSubscriptionSubscriber.java:56)
at io.servicetalk.concurrent.api.ContextPreservingSubscriber.onComplete(ContextPreservingSubscriber.java:71)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.sendComplete(FromArrayPublisher.java:113)
at io.servicetalk.concurrent.api.FromArrayPublisher$FromArraySubscription.request(FromArrayPublisher.java:89)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.api.CancellableThenSubscription.request(CancellableThenSubscription.java:62)
at io.servicetalk.transport.netty.internal.Flush$FlushSubscriber$1.request(Flush.java:86)
at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:43)
at io.servicetalk.concurrent.internal.ConcurrentSubscription.request(ConcurrentSubscription.java:122)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.requestMoreIfRequired(WriteStreamSubscriber.java:245)
at io.servicetalk.transport.netty.internal.WriteStreamSubscriber.lambda$onSubscribe$0(WriteStreamSubscriber.java:126)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:338)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
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: io.netty.channel.unix.Errors$NativeIoException: syscall:writev(..) failed: Broken pipe
at io.netty.channel.unix.FileDescriptor.writeAddresses(..)(Unknown Source)

Contributor guide

Open the contributing guide

Research direction

Start by running ClientClosureRaceTest.testPipelinedPosts and inspect ClientClosureRaceTest.runIterations at lines 137-148, using the linked CI report to reproduce the failure. Trace the ChannelOutputShutdownException through DefaultNettyPipelinedConnection and Flush; done means the test no longer fails under the reported race conditions.

Written by the indexing model from the issue text.

Assessment

Tech stack: java
Domain: networking, testing-qa
Issue type: Bug
Difficulty: 4/5
Estimated time: 3-5 days
Activity status: Stale
Clarity: Needs clarification
Newbie friendliness: 30/100

ClientClosureRaceTest.testPipelinedPosts test failure

Description

Contributor guide

Research direction

Assessment

Get new issues in your inbox