[JAVA-3966] Investigate reactive change stream test failure Created: 27/Jan/21  Updated: 30/Mar/22

Status: Backlog
Project: Java Driver
Component/s: Reactive Streams, Test Failure
Affects Version/s: None
Fix Version/s: None

Type: Task Priority: Major - P3
Reporter: Jeffrey Yemin Assignee: Unassigned
Resolution: Unresolved Votes: 0
Labels: None
Remaining Estimate: Not Specified
Time Spent: Not Specified
Original Estimate: Not Specified

Epic Link: Investigate flaky tests

 Description   

The test

  • com.mongodb.reactivestreams.client.ChangeStreamsTest
  • change-streams.json: Test drop and invalidate event types]

is failing occasionally. For example: https://evergreen.mongodb.com/task/mongo_java_driver_tests_jdk_secure__version~4.0_os~linux_topology~replicaset_auth~auth_ssl~ssl_jdk~jdk11_test_017bf9a94398abf40ffbd33de51cbbb0d7e16e47_21_01_27_02_36_05



 Comments   
Comment by Jeffrey Yemin [ 27/Jan/21 ]

[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)

Generated at Thu Feb 08 09:00:54 UTC 2024 using Jira 9.7.1#970001-sha1:2222b88b221c4928ef0de3161136cc90c8356a66.