Remove atlas data lake tests (#1815)

JAVA-5936

Author: rozza

.evergreen/.evg.yml

@@ -1469,18 +1469,6 @@ tasks:
           OCSP_MUST_STAPLE: "false"
           OCSP_TLS_SHOULD_SUCCEED: "0"
 
-  - name: "atlas-data-lake-task"
-    commands:
-      - func: "assume-aws-test-secrets-role"
-      - func: "start-mongohoused"
-      - command: shell.exec
-        type: "test"
-        params:
-          working_dir: "src"
-          script: |
-            ${PREPARE_SHELL}
-            JAVA_VERSION=${JAVA_VERSION} .evergreen/run-atlas-data-lake-test.sh
-
   - name: "atlas-search-task"
     commands:
       - command: shell.exec
@@ -2286,12 +2274,6 @@ buildvariants:
       - name: "atlas-connectivity-task"
       - name:  "atlas-x509-auth-test-task"
 
-  - name: "atlas-data-lake-test"
-    display_name: "Atlas Data Lake test"
-    run_on: "ubuntu2204-small"
-    tasks:
-      - name: "atlas-data-lake-task"
-
   - name: "reactive-streams-tck-test"
     display_name: "Reactive Streams TCK tests"
     run_on: rhel80-small

.evergreen/run-atlas-data-lake-test.sh

@@ -120,7 +120,6 @@ public final class ClusterFixture {
     public static final String MONGODB_URI_SYSTEM_PROPERTY_NAME = "org.mongodb.test.uri";
     public static final String MONGODB_API_VERSION = "org.mongodb.test.api.version";
     public static final String MONGODB_MULTI_MONGOS_URI_SYSTEM_PROPERTY_NAME = "org.mongodb.test.multi.mongos.uri";
-    public static final String DATA_LAKE_TEST_SYSTEM_PROPERTY_NAME = "org.mongodb.test.data.lake";
     public static final String ATLAS_SEARCH_TEST_SYSTEM_PROPERTY_NAME = "org.mongodb.test.atlas.search";
     private static final String MONGODB_OCSP_SHOULD_SUCCEED = "org.mongodb.test.ocsp.tls.should.succeed";
     private static final String DEFAULT_DATABASE_NAME = "JavaDriverTest";
@@ -307,11 +306,6 @@ public static synchronized ConnectionString getMultiMongosConnectionString() {
         return getConnectionStringFromSystemProperty(MONGODB_MULTI_MONGOS_URI_SYSTEM_PROPERTY_NAME);
     }
 
-    public static synchronized boolean isDataLakeTest() {
-        String isDataLakeSystemProperty = System.getProperty(DATA_LAKE_TEST_SYSTEM_PROPERTY_NAME);
-        return "true".equals(isDataLakeSystemProperty);
-    }
-
     public static synchronized ConnectionString getConnectionString() {
         if (connectionString != null) {
             return connectionString;

driver-core/src/test/functional/com/mongodb/ClusterFixture.java

@@ -36,7 +36,6 @@
 import org.junit.Before;
 import org.junit.Test;
 
-import static com.mongodb.ClusterFixture.isDataLakeTest;
 import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet;
 import static com.mongodb.ClusterFixture.isSharded;
 import static com.mongodb.client.Fixture.getMongoClientSettingsBuilder;
@@ -47,7 +46,7 @@ public class TransactionExample {
 
     @Before
     public void setUp() {
-        assumeTrue(canRunTest());
+        assumeTrue(isSharded() || isDiscoverableReplicaSet());
         MongoClientSettings.Builder builder = getMongoClientSettingsBuilder()
                 .applyConnectionString(new ConnectionString(
                         "mongodb://localhost,localhost:27018,localhost:27019/?serverSelectionTimeoutMS=5000"));
@@ -163,11 +162,4 @@ private void createCollection(final MongoClient client, final String dbName, fin
         }
     }
 
-    private boolean canRunTest() {
-        if (isDataLakeTest()) {
-            return false;
-        } else {
-            return isSharded() || isDiscoverableReplicaSet();
-        }
-    }
 }

driver-sync/src/examples/documentation/TransactionExample.java

@@ -79,7 +79,6 @@
 import java.util.stream.Collectors;
 
 import static com.mongodb.ClusterFixture.getServerVersion;
-import static com.mongodb.ClusterFixture.isDataLakeTest;
 import static com.mongodb.client.Fixture.getMongoClient;
 import static com.mongodb.client.Fixture.getMongoClientSettings;
 import static com.mongodb.client.test.CollectionHelper.getCurrentClusterTime;
@@ -284,9 +283,7 @@ public void setUp(
             throw new TestAbortedException(definition.getString("skipReason").getValue());
         }
 
-        if (!isDataLakeTest()) {
-            killAllSessions();
-        }
+        killAllSessions();
 
         startingClusterTime = addInitialDataAndGetClusterTime();
 

driver-sync/src/test/functional/com/mongodb/client/AtlasDataLakeConnectivityTest.java

@@ -24,7 +24,6 @@
 import java.util.function.Function;
 import java.util.function.Supplier;
 
-import static com.mongodb.ClusterFixture.isDataLakeTest;
 import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet;
 import static com.mongodb.ClusterFixture.isSharded;
 import static com.mongodb.ClusterFixture.serverVersionLessThan;
@@ -41,12 +40,6 @@
 public final class UnifiedTestModifications {
     public static void applyCustomizations(final TestDef def) {
 
-        // atlas-data-lake
-
-        def.skipAccordingToSpec("Data lake tests should only run on data lake")
-                .when(() -> !isDataLakeTest())
-                .directory("atlas-data-lake-testing");
-
         // change-streams
         def.skipNoncompliantReactive("error required from change stream initialization") // TODO-JAVA-5711 reason?
                 .test("change-streams", "change-streams", "Test with document comment - pre 4.4");
@@ -191,9 +184,6 @@ public static void applyCustomizations(final TestDef def) {
                 .test("command-logging-and-monitoring/tests/monitoring", "find",
                       "A successful find event with a getmore and the server kills the cursor (<= 4.4)");
 
-        def.skipNoncompliant("The driver doesn't reduce the batchSize for the getMore")
-                .test("atlas-data-lake-testing", "getMore", "A successful find event with getMore");
-
         // connection-monitoring-and-pooling
         def.skipNoncompliant("According to the test, we should clear the pool then close the connection. Our implementation"
                         + "immediately closes the failed connection, then clears the pool.")