Major Description
I have observed an NPE during an await() call on a startStreaming() observerable.
jenkins console output showing NPE
repro instructions
testStreamLifecycleSingleThread(com.couchbase.analytics.test.dcp.CouchbaseConnectorStressTest) Time elapsed: 0.133 sec <<< ERROR!
|
java.lang.NullPointerException: null
|
at com.couchbase.client.dcp.conductor.DcpChannel$7.call(DcpChannel.java:425)
|
at com.couchbase.client.dcp.conductor.DcpChannel$7.call(DcpChannel.java:399)
|
at rx.Completable.unsafeSubscribe(Completable.java:2028)
|
at rx.Completable.unsafeSubscribe(Completable.java:2076)
|
at rx.Completable.unsafeSubscribe(Completable.java:2060)
|
at rx.Completable$30.call(Completable.java:2245)
|
at rx.Completable$30.call(Completable.java:2242)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
|
at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
|
at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
|
at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
|
at rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276)
|
at rx.Subscriber.setProducer(Subscriber.java:211)
|
at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)
|
at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)
|
at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)
|
at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
|
at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
|
at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
|
at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
|
at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.internal.operators.OnSubscribeRedo$2.call(OnSubscribeRedo.java:273)
|
at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.enqueue(TrampolineScheduler.java:73)
|
at rx.internal.schedulers.TrampolineScheduler$InnerCurrentThreadScheduler.schedule(TrampolineScheduler.java:52)
|
at rx.internal.operators.OnSubscribeRedo$5.request(OnSubscribeRedo.java:361)
|
at rx.Subscriber.setProducer(Subscriber.java:209)
|
at rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:353)
|
at rx.internal.operators.OnSubscribeRedo.call(OnSubscribeRedo.java:47)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.Completable$10.call(Completable.java:573)
|
at rx.Completable$10.call(Completable.java:552)
|
at rx.Completable.unsafeSubscribe(Completable.java:2028)
|
at rx.Completable$24.call(Completable.java:1723)
|
at rx.Completable$24.call(Completable.java:1719)
|
at rx.Completable.unsafeSubscribe(Completable.java:2028)
|
at rx.Completable.unsafeSubscribe(Completable.java:2076)
|
at rx.Completable.unsafeSubscribe(Completable.java:2060)
|
at rx.Completable$30.call(Completable.java:2245)
|
at rx.Completable$30.call(Completable.java:2242)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)
|
at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)
|
at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
|
at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.fastpath(OnSubscribeFromIterable.java:173)
|
at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:86)
|
at rx.Subscriber.setProducer(Subscriber.java:211)
|
at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102)
|
at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:63)
|
at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:34)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48)
|
at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33)
|
at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
|
at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
|
at rx.Observable.unsafeSubscribe(Observable.java:9861)
|
at rx.Completable$10.call(Completable.java:573)
|
at rx.Completable$10.call(Completable.java:552)
|
at rx.Completable.unsafeSubscribe(Completable.java:2028)
|
at rx.Completable.await(Completable.java:1070)
|
at com.couchbase.analytics.test.dcp.CouchbaseConnectorStressTest.timedAwait(CouchbaseConnectorStressTest.java:274)
|
at com.couchbase.analytics.test.dcp.CouchbaseConnectorStressTest.lambda$runStreamLifecycleTest$11(CouchbaseConnectorStressTest.java:321)
|
at com.couchbase.analytics.test.dcp.CouchbaseConnectorStressTest.lambda$null$2(CouchbaseConnectorStressTest.java:212)
|