rx.exceptions.OnCompletedFailedException: CANCELLED

GitHub | vleushin | 5 months ago
  1. 0

    Should ReactiveCommandDispatcher.java check subscription status?

    GitHub | 5 months ago | vleushin
    rx.exceptions.OnCompletedFailedException: CANCELLED
  2. 0

    gRPC OOME and NPE in simple JMH benchmark

    Stack Overflow | 1 year ago | wener
    io.grpc.StatusRuntimeException: CANCELLED
  3. 0

    GitHub comment 1216#157919836

    GitHub | 1 year ago | wenerme
    io.grpc.StatusRuntimeException: CANCELLED
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    grpc OOME and NPE in simple JMH benchmark

    GitHub | 1 year ago | wenerme
    io.grpc.StatusRuntimeException: CANCELLED
  6. 0

    GitHub comment 1245#161488448

    GitHub | 1 year ago | louiscryan
    java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: CANCELLED

    4 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. io.grpc.StatusRuntimeException

      CANCELLED

      at io.grpc.Status.asRuntimeException()
    2. io.grpc
      Status.asRuntimeException
      1. io.grpc.Status.asRuntimeException(Status.java:536)
      1 frame
    3. io.grpc.stub
      ServerCalls$ServerCallStreamObserverImpl.onCompleted
      1. io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:302)
      1 frame
    4. rxjava
      OperatorDoOnEach$1.onCompleted
      1. rx.internal.util.ActionSubscriber.onCompleted(ActionSubscriber.java:49)
      2. rx.observers.SafeSubscriber.onCompleted(SafeSubscriber.java:79)
      3. rx.internal.operators.OperatorDoOnEach$1.onCompleted(OperatorDoOnEach.java:54)
      4. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      5. rx.internal.operators.OperatorDoOnEach$1.onCompleted(OperatorDoOnEach.java:54)
      6. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      7. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      8. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      9. rx.internal.operators.OperatorDoOnEach$1.onCompleted(OperatorDoOnEach.java:54)
      10. rx.internal.operators.OperatorDoOnEach$1.onCompleted(OperatorDoOnEach.java:54)
      11. rx.internal.operators.OperatorDoOnEach$1.onCompleted(OperatorDoOnEach.java:54)
      12. rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onCompleted(OperatorOnErrorResumeNextViaFunction.java:101)
      13. rx.internal.operators.OperatorDoOnEach$1.onCompleted(OperatorDoOnEach.java:54)
      14. rx.internal.operators.OperatorDoOnEach$1.onCompleted(OperatorDoOnEach.java:54)
      14 frames
    5. hystrix-core
      AbstractCommand$HystrixObservableTimeoutOperator$3.onCompleted
      1. com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.onCompleted(AbstractCommand.java:1142)
      1 frame
    6. rxjava
      Subscribers$5.onCompleted
      1. rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)
      1 frame
    7. hystrix-core
      AbstractCommand$ExecutionHookApplication$1.onCompleted
      1. com.netflix.hystrix.AbstractCommand$DeprecatedOnRunHookApplication$1.onCompleted(AbstractCommand.java:1399)
      2. com.netflix.hystrix.AbstractCommand$ExecutionHookApplication$1.onCompleted(AbstractCommand.java:1332)
      2 frames
    8. rxjava
      OnSubscribeMap$MapSubscriber.onCompleted
      1. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      1 frame
    9. rx.internal.producers
      SingleDelayedProducer.setValue
      1. rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:110)
      2. rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85)
      2 frames
    10. rxjava
      OnSubscribeMap$MapSubscriber.onCompleted
      1. rx.internal.operators.OperatorToObservableList$1.onCompleted(OperatorToObservableList.java:98)
      2. rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:662)
      3. rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:574)
      4. rx.internal.operators.OperatorMerge$MergeSubscriber.onCompleted(OperatorMerge.java:283)
      5. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      6. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      6 frames
    11. rx.internal.producers
      SingleDelayedProducer.setValue
      1. rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:110)
      2. rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85)
      2 frames
    12. rxjava
      OnSubscribeMap$MapSubscriber.onCompleted
      1. rx.internal.operators.OperatorToObservableList$1.onCompleted(OperatorToObservableList.java:98)
      2. rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:662)
      3. rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:574)
      4. rx.internal.operators.OperatorMerge$InnerSubscriber.onCompleted(OperatorMerge.java:863)
      5. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      6. rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onCompleted(OperatorOnErrorResumeNextViaFunction.java:101)
      7. rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)
      7 frames
    13. lettuce
      CommandHandler.channelRead
      1. com.lambdaworks.redis.ReactiveCommandDispatcher$ObservableCommand.complete(ReactiveCommandDispatcher.java:127)
      2. com.lambdaworks.redis.protocol.CommandHandler.decode(CommandHandler.java:187)
      3. com.lambdaworks.redis.protocol.CommandHandler.channelRead(CommandHandler.java:153)
      3 frames
    14. Netty
      DefaultThreadFactory$DefaultRunnableDecorator.run
      1. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      2. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:334)
      3. io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:326)
      4. io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
      5. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      6. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:334)
      7. io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:326)
      8. io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
      9. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      10. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:334)
      11. io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:326)
      12. io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
      13. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      14. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:334)
      15. io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:326)
      16. io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1320)
      17. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      18. io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:334)
      19. io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:905)
      20. io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:123)
      21. io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:563)
      22. io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:504)
      23. io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:418)
      24. io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:390)
      25. io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:742)
      26. io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:145)
      26 frames
    15. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame