Skip to content

Commit ee3f346

Browse files
committed
JAVA-2830: Temporarily disable a few tailable cursor tests on 3.7.x sharded clusters
Waiting on a SERVER bug to be fixed, then these can be re-enabled
1 parent 073e835 commit ee3f346

File tree

3 files changed

+6
-0
lines changed

3 files changed

+6
-0
lines changed

driver-core/src/test/functional/com/mongodb/operation/AsyncQueryBatchCursorFunctionalSpecification.groovy

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ import static com.mongodb.ClusterFixture.getReadConnectionSource
5252
import static com.mongodb.ClusterFixture.getReferenceCountAfterTimeout
5353
import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet
5454
import static com.mongodb.ClusterFixture.isSharded
55+
import static com.mongodb.ClusterFixture.serverVersionAtLeast
5556
import static com.mongodb.connection.ServerHelper.waitForLastRelease
5657
import static com.mongodb.connection.ServerHelper.waitForRelease
5758
import static com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult
@@ -261,6 +262,7 @@ class AsyncQueryBatchCursorFunctionalSpecification extends OperationFunctionalSp
261262
}
262263

263264
@Category(Slow)
265+
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
264266
def 'should block waiting for next batch on a tailable cursor'() {
265267
collectionHelper.create(collectionName, new CreateCollectionOptions().capped(true).sizeInBytes(1000))
266268
collectionHelper.insertDocuments(new DocumentCodec(), new Document('_id', 1).append('ts', new BsonTimestamp(5, 0)))

driver-core/src/test/functional/com/mongodb/operation/ChangeStreamOperationSpecification.groovy

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ import spock.lang.IgnoreIf
4040

4141
import static com.mongodb.ClusterFixture.getAsyncCluster
4242
import static com.mongodb.ClusterFixture.getCluster
43+
import static com.mongodb.ClusterFixture.isSharded
4344
import static com.mongodb.ClusterFixture.isStandalone
4445
import static com.mongodb.ClusterFixture.serverVersionAtLeast
4546
import static com.mongodb.connection.ServerHelper.waitForLastRelease
@@ -293,6 +294,7 @@ class ChangeStreamOperationSpecification extends OperationFunctionalSpecificatio
293294
async << [true, false]
294295
}
295296

297+
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
296298
def 'should act like a tailable cursor'() {
297299
given:
298300
def helper = getHelper()

driver-core/src/test/functional/com/mongodb/operation/QueryBatchCursorFunctionalSpecification.groovy

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,7 @@ class QueryBatchCursorFunctionalSpecification extends OperationFunctionalSpecifi
187187

188188
@SuppressWarnings('EmptyCatchBlock')
189189
@Category(Slow)
190+
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
190191
def 'should block waiting for next batch on a tailable cursor'() {
191192
given:
192193
def connection = connectionSource.getConnection()
@@ -235,6 +236,7 @@ class QueryBatchCursorFunctionalSpecification extends OperationFunctionalSpecifi
235236
}
236237

237238
@Category(Slow)
239+
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
238240
def 'test try next with tailable'() {
239241
collectionHelper.create(collectionName, new CreateCollectionOptions().capped(true).sizeInBytes(1000))
240242
collectionHelper.insertDocuments(new DocumentCodec(), new Document('_id', 1).append('ts', new BsonTimestamp(5, 0)))

0 commit comments

Comments
 (0)