rx.exceptions.OnErrorNotImplementedException

Couchbase JIRA | cbax007 | 2 years ago
  1. 0

    Using the following simple scala code I am able to produce a ConcurrentModificationException pretty consistently when connecting to a multi-node cluster with many buckets: {code} import com.couchbase.client.java._ object InitTest extends App{ import collection.JavaConversions._ val bucketNames = List("cache","session","clicks","campaignevent","datacenter","shorturl","metering") val serverUris = List("build04", "build02", "build01") val password = "foo" val cluster = CouchbaseAsyncCluster.create(serverUris) bucketNames foreach(cluster.openBucket(_, password)) Thread.sleep(30000) } {code} The exception stack trace is as follows: {code} rx.exceptions.OnErrorNotImplementedException at rx.Observable$30.onError(Observable.java:7092) at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:154) at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:111) at rx.internal.operators.OperatorMap$1.onError(OperatorMap.java:49) at rx.internal.operators.OperatorDoOnEach$1.onError(OperatorDoOnEach.java:70) at rx.internal.operators.OperatorSingle$1.onError(OperatorSingle.java:90) at rx.internal.operators.OperatorTakeLast$1.onError(OperatorTakeLast.java:65) at rx.internal.operators.OperatorMerge$MergeSubscriber.innerError(OperatorMerge.java:429) at rx.internal.operators.OperatorMerge$MergeSubscriber.onError(OperatorMerge.java:404) at rx.internal.operators.OperatorMap$1.onError(OperatorMap.java:49) at rx.internal.operators.OperatorMerge$MergeSubscriber.innerError(OperatorMerge.java:429) at rx.internal.operators.OperatorMerge$MergeSubscriber.access$800(OperatorMerge.java:93) at rx.internal.operators.OperatorMerge$InnerSubscriber.onError(OperatorMerge.java:552) at rx.Observable.unsafeSubscribe(Observable.java:7311) at rx.internal.operators.OperatorMerge$MergeSubscriber.handleNewSource(OperatorMerge.java:188) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:158) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:93) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:41) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:30) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable.subscribe(Observable.java:7393) at rx.Observable.subscribe(Observable.java:7083) at com.couchbase.client.core.RequestHandler$1.call(RequestHandler.java:157) at com.couchbase.client.core.RequestHandler$1.call(RequestHandler.java:151) at rx.Observable$31.onNext(Observable.java:7139) at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:130) at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onNext(SubjectSubscriptionManager.java:224) at rx.subjects.PublishSubject.onNext(PublishSubject.java:121) at com.couchbase.client.core.config.DefaultConfigurationProvider.upsertBucketConfig(DefaultConfigurationProvider.java:386) at com.couchbase.client.core.config.DefaultConfigurationProvider.access$000(DefaultConfigurationProvider.java:91) at com.couchbase.client.core.config.DefaultConfigurationProvider$7.call(DefaultConfigurationProvider.java:257) at com.couchbase.client.core.config.DefaultConfigurationProvider$7.call(DefaultConfigurationProvider.java:254) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.operators.OperatorDoOnEach$1.onNext(OperatorDoOnEach.java:84) at rx.internal.operators.OperatorOnErrorResumeNextViaObservable$1.onNext(OperatorOnErrorResumeNextViaObservable.java:64) at rx.internal.operators.OperatorTake$1.onNext(OperatorTake.java:67) at rx.internal.operators.OperatorMerge$InnerSubscriber.emit(OperatorMerge.java:635) at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:545) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.operators.OperatorMerge$InnerSubscriber.emit(OperatorMerge.java:635) at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:545) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at com.couchbase.client.core.utils.Buffers$2$1.onNext(Buffers.java:90) at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:130) at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onNext(SubjectSubscriptionManager.java:224) at rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:101) at com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:199) at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:47) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) at java.util.concurrent.FutureTask.run(FutureTask.java:166) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:722) Caused by: java.util.ConcurrentModificationException at java.util.HashMap$HashIterator.nextEntry(HashMap.java:894) at java.util.HashMap$ValueIterator.next(HashMap.java:922) at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:96) at rx.Subscriber.setProducer(Subscriber.java:139) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:47) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:33) at rx.Observable.unsafeSubscribe(Observable.java:7304) ... 58 more {code}

    Couchbase JIRA | 2 years ago | cbax007
    rx.exceptions.OnErrorNotImplementedException
  2. 0

    Using the following simple scala code I am able to produce a ConcurrentModificationException pretty consistently when connecting to a multi-node cluster with many buckets: {code} import com.couchbase.client.java._ object InitTest extends App{ import collection.JavaConversions._ val bucketNames = List("cache","session","clicks","campaignevent","datacenter","shorturl","metering") val serverUris = List("build04", "build02", "build01") val password = "foo" val cluster = CouchbaseAsyncCluster.create(serverUris) bucketNames foreach(cluster.openBucket(_, password)) Thread.sleep(30000) } {code} The exception stack trace is as follows: {code} rx.exceptions.OnErrorNotImplementedException at rx.Observable$30.onError(Observable.java:7092) at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:154) at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:111) at rx.internal.operators.OperatorMap$1.onError(OperatorMap.java:49) at rx.internal.operators.OperatorDoOnEach$1.onError(OperatorDoOnEach.java:70) at rx.internal.operators.OperatorSingle$1.onError(OperatorSingle.java:90) at rx.internal.operators.OperatorTakeLast$1.onError(OperatorTakeLast.java:65) at rx.internal.operators.OperatorMerge$MergeSubscriber.innerError(OperatorMerge.java:429) at rx.internal.operators.OperatorMerge$MergeSubscriber.onError(OperatorMerge.java:404) at rx.internal.operators.OperatorMap$1.onError(OperatorMap.java:49) at rx.internal.operators.OperatorMerge$MergeSubscriber.innerError(OperatorMerge.java:429) at rx.internal.operators.OperatorMerge$MergeSubscriber.access$800(OperatorMerge.java:93) at rx.internal.operators.OperatorMerge$InnerSubscriber.onError(OperatorMerge.java:552) at rx.Observable.unsafeSubscribe(Observable.java:7311) at rx.internal.operators.OperatorMerge$MergeSubscriber.handleNewSource(OperatorMerge.java:188) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:158) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:93) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:41) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:30) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable$1.call(Observable.java:145) at rx.Observable$1.call(Observable.java:137) at rx.Observable.subscribe(Observable.java:7393) at rx.Observable.subscribe(Observable.java:7083) at com.couchbase.client.core.RequestHandler$1.call(RequestHandler.java:157) at com.couchbase.client.core.RequestHandler$1.call(RequestHandler.java:151) at rx.Observable$31.onNext(Observable.java:7139) at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:130) at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onNext(SubjectSubscriptionManager.java:224) at rx.subjects.PublishSubject.onNext(PublishSubject.java:121) at com.couchbase.client.core.config.DefaultConfigurationProvider.upsertBucketConfig(DefaultConfigurationProvider.java:386) at com.couchbase.client.core.config.DefaultConfigurationProvider.access$000(DefaultConfigurationProvider.java:91) at com.couchbase.client.core.config.DefaultConfigurationProvider$7.call(DefaultConfigurationProvider.java:257) at com.couchbase.client.core.config.DefaultConfigurationProvider$7.call(DefaultConfigurationProvider.java:254) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.operators.OperatorDoOnEach$1.onNext(OperatorDoOnEach.java:84) at rx.internal.operators.OperatorOnErrorResumeNextViaObservable$1.onNext(OperatorOnErrorResumeNextViaObservable.java:64) at rx.internal.operators.OperatorTake$1.onNext(OperatorTake.java:67) at rx.internal.operators.OperatorMerge$InnerSubscriber.emit(OperatorMerge.java:635) at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:545) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.operators.OperatorMerge$InnerSubscriber.emit(OperatorMerge.java:635) at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:545) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at com.couchbase.client.core.utils.Buffers$2$1.onNext(Buffers.java:90) at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:130) at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onNext(SubjectSubscriptionManager.java:224) at rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:101) at com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:199) at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:47) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) at java.util.concurrent.FutureTask.run(FutureTask.java:166) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:722) Caused by: java.util.ConcurrentModificationException at java.util.HashMap$HashIterator.nextEntry(HashMap.java:894) at java.util.HashMap$ValueIterator.next(HashMap.java:922) at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:96) at rx.Subscriber.setProducer(Subscriber.java:139) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:47) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:33) at rx.Observable.unsafeSubscribe(Observable.java:7304) ... 58 more {code}

    Couchbase JIRA | 2 years ago | cbax007
    rx.exceptions.OnErrorNotImplementedException
  3. 0

    ConcurrentModificationException

    GitHub | 3 years ago | ScarecrowKrone
    java.util.ConcurrentModificationException
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    latest api crash

    GitHub | 3 years ago | denwd
    java.util.ConcurrentModificationException
  6. 0

    ConcurrentModificationException on startup

    GitHub | 3 years ago | agouge
    java.util.ConcurrentModificationException

    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. java.util.ConcurrentModificationException

      No message provided

      at java.util.HashMap$HashIterator.nextEntry()
    2. Java RT
      HashMap$ValueIterator.next
      1. java.util.HashMap$HashIterator.nextEntry(HashMap.java:894)
      2. java.util.HashMap$ValueIterator.next(HashMap.java:922)
      2 frames
    3. rxjava
      Observable.subscribe
      1. rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:96)
      2. rx.Subscriber.setProducer(Subscriber.java:139)
      3. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:47)
      4. rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:33)
      5. rx.Observable.unsafeSubscribe(Observable.java:7304)
      6. rx.internal.operators.OperatorMerge$MergeSubscriber.handleNewSource(OperatorMerge.java:188)
      7. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:158)
      8. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:93)
      9. rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55)
      10. rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:41)
      11. rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:30)
      12. rx.Observable$1.call(Observable.java:145)
      13. rx.Observable$1.call(Observable.java:137)
      14. rx.Observable$1.call(Observable.java:145)
      15. rx.Observable$1.call(Observable.java:137)
      16. rx.Observable$1.call(Observable.java:145)
      17. rx.Observable$1.call(Observable.java:137)
      18. rx.Observable$1.call(Observable.java:145)
      19. rx.Observable$1.call(Observable.java:137)
      20. rx.Observable$1.call(Observable.java:145)
      21. rx.Observable$1.call(Observable.java:137)
      22. rx.Observable$1.call(Observable.java:145)
      23. rx.Observable$1.call(Observable.java:137)
      24. rx.Observable$1.call(Observable.java:145)
      25. rx.Observable$1.call(Observable.java:137)
      26. rx.Observable$1.call(Observable.java:145)
      27. rx.Observable$1.call(Observable.java:137)
      28. rx.Observable.subscribe(Observable.java:7393)
      29. rx.Observable.subscribe(Observable.java:7083)
      29 frames
    4. com.couchbase.client
      RequestHandler$1.call
      1. com.couchbase.client.core.RequestHandler$1.call(RequestHandler.java:157)
      2. com.couchbase.client.core.RequestHandler$1.call(RequestHandler.java:151)
      2 frames
    5. rxjava
      PublishSubject.onNext
      1. rx.Observable$31.onNext(Observable.java:7139)
      2. rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:130)
      3. rx.subjects.SubjectSubscriptionManager$SubjectObserver.onNext(SubjectSubscriptionManager.java:224)
      4. rx.subjects.PublishSubject.onNext(PublishSubject.java:121)
      4 frames
    6. com.couchbase.client
      DefaultConfigurationProvider$7.call
      1. com.couchbase.client.core.config.DefaultConfigurationProvider.upsertBucketConfig(DefaultConfigurationProvider.java:386)
      2. com.couchbase.client.core.config.DefaultConfigurationProvider.access$000(DefaultConfigurationProvider.java:91)
      3. com.couchbase.client.core.config.DefaultConfigurationProvider$7.call(DefaultConfigurationProvider.java:257)
      4. com.couchbase.client.core.config.DefaultConfigurationProvider$7.call(DefaultConfigurationProvider.java:254)
      4 frames
    7. rxjava
      OperatorMap$1.onNext
      1. rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55)
      2. rx.internal.operators.OperatorDoOnEach$1.onNext(OperatorDoOnEach.java:84)
      3. rx.internal.operators.OperatorOnErrorResumeNextViaObservable$1.onNext(OperatorOnErrorResumeNextViaObservable.java:64)
      4. rx.internal.operators.OperatorTake$1.onNext(OperatorTake.java:67)
      5. rx.internal.operators.OperatorMerge$InnerSubscriber.emit(OperatorMerge.java:635)
      6. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:545)
      7. rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55)
      8. rx.internal.operators.OperatorMerge$InnerSubscriber.emit(OperatorMerge.java:635)
      9. rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:545)
      10. rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55)
      10 frames
    8. com.couchbase.client
      Buffers$2$1.onNext
      1. com.couchbase.client.core.utils.Buffers$2$1.onNext(Buffers.java:90)
      1 frame
    9. rxjava
      AsyncSubject.onCompleted
      1. rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:130)
      2. rx.subjects.SubjectSubscriptionManager$SubjectObserver.onNext(SubjectSubscriptionManager.java:224)
      3. rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:101)
      3 frames
    10. com.couchbase.client
      AbstractGenericHandler$1.call
      1. com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:199)
      1 frame
    11. rxjava
      ScheduledAction.run
      1. rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:47)
      1 frame
    12. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
      2. java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
      3. java.util.concurrent.FutureTask.run(FutureTask.java:166)
      4. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
      5. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
      6. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      7. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      8. java.lang.Thread.run(Thread.java:722)
      8 frames