Add flaky annotation to flaky tests

Author: katcharov

Diff for: driver-sync/src/test/functional/com/mongodb/client/AbstractClientSideEncryptionDecryptionEventsTest.java

@@ -30,6 +30,7 @@
 import com.mongodb.event.CommandSucceededEvent;
 import com.mongodb.fixture.EncryptionFixture;
 import com.mongodb.internal.connection.TestCommandListener;
+import com.mongodb.test.FlakyTest;
 import org.bson.BsonBinary;
 import org.bson.BsonDocument;
 import org.bson.BsonString;
@@ -174,7 +175,7 @@ public void networkError() {
         assertDoesNotThrow(() -> commandListener.getCommandFailedEvent("aggregate"));
     }
 
-    @Test
+    @FlakyTest(maxAttempts = 3)
     public void decryptError() {
         MongoCollection<Document> decryptionEvents = encryptedClient
                 .getDatabase(getDefaultDatabaseName())

Diff for: driver-sync/src/test/functional/com/mongodb/client/AbstractClientSideOperationsTimeoutProseTest.java

@@ -282,7 +282,7 @@ public void testBlockingIterationMethodsChangeStream() {
     }
 
     @DisplayName("6. GridFS Upload - uploads via openUploadStream can be timed out")
-    @Test
+    @FlakyTest(maxAttempts = 3)
     public void testGridFSUploadViaOpenUploadStreamTimeout() {
         assumeTrue(serverVersionAtLeast(4, 4));
         long rtt = ClusterFixture.getPrimaryRTT();
@@ -461,7 +461,7 @@ public void test8ServerSelectionHandshake(final String ignoredTestName, final in
 
     @SuppressWarnings("try")
     @DisplayName("9. End Session. The timeout specified via the MongoClient timeoutMS option")
-    @Test
+    @FlakyTest(maxAttempts = 3)
     public void test9EndSessionClientTimeout() {
         assumeTrue(serverVersionAtLeast(4, 4));
         assumeFalse(isStandalone());