[2021/01/27 02:44:17.249] com.mongodb.reactivestreams.client.ChangeStreamsTest > shouldPassAllOutcomes[change-streams.json: Test drop and invalidate event types] FAILED
|
[2021/01/27 02:44:17.249] com.mongodb.MongoException: next() called after the cursor was closed.
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor.next(AsyncQueryBatchCursor.java:191)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor.next(AsyncQueryBatchCursor.java:138)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$1.apply(AsyncChangeStreamBatchCursor.java:77)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.resumeableOperation(AsyncChangeStreamBatchCursor.java:214)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.next(AsyncChangeStreamBatchCursor.java:73)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.BatchCursor.lambda$next$0(BatchCursor.java:35)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoCreate.subscribe(MonoCreate.java:57)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:67)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:67)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.Mono.subscribe(Mono.java:3873)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.Mono.subscribeWith(Mono.java:3979)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.Mono.subscribe(Mono.java:3758)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.BatchCursorPublisher.recurseCursor(BatchCursorPublisher.java:154)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.BatchCursorPublisher.lambda$recurseCursor$7(BatchCursorPublisher.java:151)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:311)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:932)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:932)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:129)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.MongoOperationPublisher.lambda$sinkToCallback$30(MongoOperationPublisher.java:548)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$3.onResult(AsyncChangeStreamBatchCursor.java:194)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$3.onResult(AsyncChangeStreamBatchCursor.java:170)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:219)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:214)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor.next(AsyncQueryBatchCursor.java:213)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor.next(AsyncQueryBatchCursor.java:138)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$1.apply(AsyncChangeStreamBatchCursor.java:77)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.resumeableOperation(AsyncChangeStreamBatchCursor.java:214)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.next(AsyncChangeStreamBatchCursor.java:73)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.BatchCursor.lambda$next$0(BatchCursor.java:35)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoCreate.subscribe(MonoCreate.java:57)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:67)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:67)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.Mono.subscribe(Mono.java:3873)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.Mono.subscribeWith(Mono.java:3979)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.Mono.subscribe(Mono.java:3758)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.BatchCursorPublisher.recurseCursor(BatchCursorPublisher.java:154)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.BatchCursorPublisher.lambda$recurseCursor$7(BatchCursorPublisher.java:151)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onNext(MonoPeekTerminal.java:176)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:846)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:846)
|
[2021/01/27 02:44:17.249] at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:156)
|
[2021/01/27 02:44:17.249] at com.mongodb.reactivestreams.client.internal.MongoOperationPublisher.lambda$sinkToCallback$30(MongoOperationPublisher.java:550)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$3.onResult(AsyncChangeStreamBatchCursor.java:192)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$3.onResult(AsyncChangeStreamBatchCursor.java:170)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:219)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:214)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor.handleGetMoreQueryResult(AsyncQueryBatchCursor.java:358)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor.access$600(AsyncQueryBatchCursor.java:56)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor$CommandResultSingleResultCallback.onResult(AsyncQueryBatchCursor.java:390)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.operation.AsyncQueryBatchCursor$CommandResultSingleResultCallback.onResult(AsyncQueryBatchCursor.java:363)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor$2.onResult(DefaultServer.java:286)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.CommandProtocolImpl$1.onResult(CommandProtocolImpl.java:94)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection$2.onResult(DefaultConnectionPool.java:530)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:142)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:462)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:439)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(InternalStreamConnection.java:744)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(InternalStreamConnection.java:711)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:581)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:578)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.AsynchronousChannelStream$BasicCompletionHandler.completed(AsynchronousChannelStream.java:250)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.AsynchronousChannelStream$BasicCompletionHandler.completed(AsynchronousChannelStream.java:233)
|
[2021/01/27 02:44:17.249] at com.mongodb.internal.connection.tlschannel.async.AsynchronousTlsChannel.lambda$read$4(AsynchronousTlsChannel.java:122)
|
[2021/01/27 02:44:17.249] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
|
[2021/01/27 02:44:17.249] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
|
[2021/01/27 02:44:17.249] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
|
[2021/01/27 02:44:17.249] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
|
[2021/01/27 02:44:17.249] at java.base/java.lang.Thread.run(Thread.java:834)
|