From 168eeafe98c1359e55c61be845fc900b364b6fdf Mon Sep 17 00:00:00 2001
From: Maciej Mierzwa <dev.maciej.mierzwa@gmail.com>
Date: Tue, 7 Nov 2023 21:07:43 +0100
Subject: [PATCH] force cluster manager

Signed-off-by: Maciej Mierzwa <dev.maciej.mierzwa@gmail.com>
---
 .../java/org/opensearch/security/SearchOperationTest.java       | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/integrationTest/java/org/opensearch/security/SearchOperationTest.java b/src/integrationTest/java/org/opensearch/security/SearchOperationTest.java
index 6210fa353c..98a65d1465 100644
--- 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(