force cluster manager

Signed-off-by: Maciej Mierzwa <[email protected]>
MaciejMierzwa · Nov 7, 2023 · 168eeaf · 168eeaf
1 parent 3fccf57
commit 168eeaf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/integrationTest/java/org/opensearch/security/SearchOperationTest.java b/src/integrationTest/java/org/opensearch/security/SearchOperationTest.java
@@ -448,10 +448,12 @@ public static void createTestData() {
     @Before
     public void retrieveClusterClient() {
         this.internalClient = cluster.getInternalNodeClient();
+        cluster.setPrimaryNode("cluster_manager_0");
     }
 
     @After
     public void cleanData() throws ExecutionException, InterruptedException {
+        cluster.setPrimaryNode(null);
         Stopwatch stopwatch = Stopwatch.createStarted();
         IndicesAdminClient indices = internalClient.admin().indices();
         List<String> indicesToBeDeleted = List.of(