java.lang.IndexOutOfBoundsException: Source emitted more than one item

GitHub | ilayaperumalg | 6 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.

Root Cause Analysis

  1. java.lang.IndexOutOfBoundsException

    Source emitted more than one item

    at reactor.core.publisher.MonoSingle$SingleSubscriber.onNext()
  2. reactor.core.publisher
    FluxSubscribeOn$SubscribeOnPipeline.onComplete
    1. reactor.core.publisher.MonoSingle$SingleSubscriber.onNext(MonoSingle.java:130)[reactor-core-3.0.0.RC1.jar!/:na]
    2. reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:636)[reactor-core-3.0.0.RC1.jar!/:na]
    3. reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:511)[reactor-core-3.0.0.RC1.jar!/:na]
    4. reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:994)[reactor-core-3.0.0.RC1.jar!/:na]
    5. reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:95)[reactor-core-3.0.0.RC1.jar!/:na]
    6. reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:59)[reactor-core-3.0.0.RC1.jar!/:na]
    7. reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:360)[reactor-core-3.0.0.RC1.jar!/:na]
    8. reactor.core.publisher.MonoFlatMap$FlattenSubscriber$InnerSubscriber.onNext(MonoFlatMap.java:195)[reactor-core-3.0.0.RC1.jar!/:na]
    9. reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:362)[reactor-core-3.0.0.RC1.jar!/:na]
    10. reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:595)[reactor-core-3.0.0.RC1.jar!/:na]
    11. reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:220)[reactor-core-3.0.0.RC1.jar!/:na]
    12. reactor.core.publisher.FluxBuffer$BufferExactSubscriber.onComplete(FluxBuffer.java:182)[reactor-core-3.0.0.RC1.jar!/:na]
    13. reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:177)[reactor-core-3.0.0.RC1.jar!/:na]
    14. reactor.core.publisher.FluxConcatArray.subscribe(FluxConcatArray.java:96)[reactor-core-3.0.0.RC1.jar!/:na]
    15. reactor.core.publisher.FluxBuffer.subscribe(FluxBuffer.java:75)[reactor-core-3.0.0.RC1.jar!/:na]
    16. reactor.core.publisher.FluxFlattenIterable.subscribe(FluxFlattenIterable.java:103)[reactor-core-3.0.0.RC1.jar!/:na]
    17. reactor.core.publisher.MonoFlatMap$FlattenSubscriber.onNext(MonoFlatMap.java:158)[reactor-core-3.0.0.RC1.jar!/:na]
    18. reactor.core.publisher.FluxResume$ResumeSubscriber.onNext(FluxResume.java:75)[reactor-core-3.0.0.RC1.jar!/:na]
    19. reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:173)[reactor-core-3.0.0.RC1.jar!/:na]
    20. reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:131)[reactor-core-3.0.0.RC1.jar!/:na]
    21. reactor.core.publisher.Operators$DeferredScalarSubscriber.complete(Operators.java:797)[reactor-core-3.0.0.RC1.jar!/:na]
    22. reactor.core.publisher.MonoThenApply$MonoThenApplyManager$SecondSubscriber.onNext(MonoThenApply.java:204)[reactor-core-3.0.0.RC1.jar!/:na]
    23. reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:125)[reactor-core-3.0.0.RC1.jar!/:na]
    24. reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:320)[reactor-core-3.0.0.RC1.jar!/:na]
    25. reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:115)[reactor-core-3.0.0.RC1.jar!/:na]
    26. reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:390)[reactor-core-3.0.0.RC1.jar!/:na]
    27. reactor.core.publisher.Operators$DeferredScalarSubscriber.complete(Operators.java:797)[reactor-core-3.0.0.RC1.jar!/:na]
    28. reactor.core.publisher.MonoReduce$ReduceSubscriber.onComplete(MonoReduce.java:152)[reactor-core-3.0.0.RC1.jar!/:na]
    29. reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:157)[reactor-core-3.0.0.RC1.jar!/:na]
    30. reactor.core.publisher.FluxSubscribeOn$SubscribeOnPipeline.onComplete(FluxSubscribeOn.java:137)[reactor-core-3.0.0.RC1.jar!/:na]
    30 frames
  3. reactor.ipc.netty
    NettyChannelHandler$InboundSink.request
    1. reactor.ipc.netty.common.NettyChannelHandler$InboundSink.drain(NettyChannelHandler.java:696)[reactor-netty-0.5.0.M2.jar!/:na]
    2. reactor.ipc.netty.common.NettyChannelHandler$InboundSink.request(NettyChannelHandler.java:772)[reactor-netty-0.5.0.M2.jar!/:na]
    2 frames
  4. reactor.core.publisher
    FluxSubscribeOn$SubscribeOnPipeline.onSubscribe
    1. reactor.core.publisher.Operators$DeferredSubscription.set(Operators.java:598)[reactor-core-3.0.0.RC1.jar!/:na]
    2. reactor.core.publisher.FluxSubscribeOn$SubscribeOnPipeline.onSubscribe(FluxSubscribeOn.java:117)[reactor-core-3.0.0.RC1.jar!/:na]
    2 frames
  5. reactor.ipc.netty
    NettyChannelHandler.subscribe
    1. reactor.ipc.netty.common.NettyChannelHandler.subscribe(NettyChannelHandler.java:543)[reactor-netty-0.5.0.M2.jar!/:na]
    1 frame
  6. reactor.core.publisher
    FluxSubscribeOn$SourceSubscribeTask.run
    1. reactor.core.publisher.FluxSource.subscribe(FluxSource.java:59)[reactor-core-3.0.0.RC1.jar!/:na]
    2. reactor.core.publisher.FluxSubscribeOn$SourceSubscribeTask.run(FluxSubscribeOn.java:235)[reactor-core-3.0.0.RC1.jar!/:na]
    2 frames
  7. reactor.core.scheduler
    ExecutorScheduler$ExecutorTrackedRunnable.run
    1. reactor.core.scheduler.ExecutorScheduler$ExecutorTrackedRunnable.run(ExecutorScheduler.java:134)[reactor-core-3.0.0.RC1.jar!/:na]
    1 frame
  8. Netty
    SingleThreadEventExecutor$5.run
    1. io.netty.util.concurrent.SingleThreadEventExecutor.safeExecute(SingleThreadEventExecutor.java:451)[netty-all-4.1.3.Final.jar!/:4.1.3.Final]
    2. io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)[netty-all-4.1.3.Final.jar!/:4.1.3.Final]
    3. io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:401)[netty-all-4.1.3.Final.jar!/:4.1.3.Final]
    4. io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:877)[netty-all-4.1.3.Final.jar!/:4.1.3.Final]
    4 frames
  9. Java RT
    Thread.run
    1. java.lang.Thread.run(Thread.java:745)[na:1.8.0_20]
    1 frame