[BUG] Getting DeadlineTimeoutException error during security tests after upgrading to 3.0

Signed-off-by: Andriy Redko <[email protected]>

Author: reta

notifications/notifications/src/test/kotlin/org/opensearch/integtest/PluginRestTestCase.kt

@@ -111,13 +111,19 @@ abstract class PluginRestTestCase : OpenSearchRestTestCase() {
                     // create adminDN (super-admin) client
                     val uri = javaClass.classLoader.getResource("security/sample.pem").toURI()
                     val configPath = PathUtils.get(uri).parent.toAbsolutePath()
-                    SecureRestClientBuilder(settings, configPath).setSocketTimeout(60000).build()
+                    SecureRestClientBuilder(settings, configPath)
+                        .setSocketTimeout(60000)
+                        .setConnectionRequestTimeout(180000)
+                        .build()
                 }
                 false -> {
                     // create client with passed user
                     val userName = System.getProperty("user")
                     val password = System.getProperty("password")
-                    SecureRestClientBuilder(hosts, isHttps(), userName, password).setSocketTimeout(60000).build()
+                    SecureRestClientBuilder(hosts, isHttps(), userName, password)
+                        .setSocketTimeout(60000)
+                        .setConnectionRequestTimeout(180000)
+                        .build()
                 }
             }
         } else {

notifications/notifications/src/test/kotlin/org/opensearch/integtest/SecurityNotificationIT.kt

@@ -35,17 +35,17 @@ class SecurityNotificationIT : PluginRestTestCase() {
 
     @Before
     fun create() {
-
-        if (userClient == null) {
-            createUser(user, user, arrayOf())
-            userClient = SecureRestClientBuilder(clusterHosts.toTypedArray(), isHttps(), user, user).setSocketTimeout(60000).build()
-        }
+        createUser(user, user, arrayOf())
+        userClient = SecureRestClientBuilder(clusterHosts.toTypedArray(), isHttps(), user, user)
+            .setSocketTimeout(60000)
+            .setConnectionRequestTimeout(180000)
+            .build()
     }
 
     @After
     fun cleanup() {
-
         userClient?.close()
+        userClient = null
     }
 
     fun `test Create slack notification config with user that has create Notification permission`() {