fix compile issues

Signed-off-by: bansvaru <bansvaru@amazon.com>
opensearch-project · Sep 4, 2023 · 74890da · 74890da
1 parent 04d220d
commit 74890da
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 7 deletions.
diff --git a/server/src/main/java/org/opensearch/node/Node.java b/server/src/main/java/org/opensearch/node/Node.java
@@ -682,7 +682,8 @@ protected Node(
                     repositoriesServiceReference::get,
                     settings,
                     clusterService.getClusterSettings(),
-                    threadPool::preciseRelativeTimeInNanos
+                    threadPool::preciseRelativeTimeInNanos,
+                    threadPool
                 );
             } else {
                 remoteClusterStateService = null;

diff --git a/server/src/test/java/org/opensearch/gateway/GatewayMetaStatePersistedStateTests.java b/server/src/test/java/org/opensearch/gateway/GatewayMetaStatePersistedStateTests.java
@@ -458,7 +458,8 @@ public void testDataOnlyNodePersistence() throws Exception {
                         ),
                         settings,
                         new ClusterSettings(settings, ClusterSettings.BUILT_IN_CLUSTER_SETTINGS),
-                        () -> 0L
+                        () -> 0L,
+                        new TestThreadPool(getClass().getName())
                     );
                 } else {
                     return null;

diff --git a/server/src/test/java/org/opensearch/gateway/remote/RemoteClusterStateServiceTests.java b/server/src/test/java/org/opensearch/gateway/remote/RemoteClusterStateServiceTests.java
@@ -85,8 +85,8 @@ public void setup() {
             repositoriesServiceSupplier,
             settings,
             new ClusterSettings(settings, ClusterSettings.BUILT_IN_CLUSTER_SETTINGS),
-            new TestThreadPool(getClass().getName()),
-            () -> 0L
+            () -> 0L,
+            new TestThreadPool(getClass().getName())
         );
     }
 
@@ -105,8 +105,8 @@ public void testFailInitializationWhenRemoteStateDisabled() throws IOException {
                 repositoriesServiceSupplier,
                 settings,
                 new ClusterSettings(settings, ClusterSettings.BUILT_IN_CLUSTER_SETTINGS),
-                new TestThreadPool(getClass().getName()),
-                () -> 0L
+                () -> 0L,
+                new TestThreadPool(getClass().getName())
             )
         );
     }

diff --git a/test/framework/src/main/java/org/opensearch/gateway/MockGatewayMetaState.java b/test/framework/src/main/java/org/opensearch/gateway/MockGatewayMetaState.java
@@ -48,6 +48,7 @@
 import org.opensearch.gateway.remote.RemoteClusterStateService;
 import org.opensearch.plugins.MetadataUpgrader;
 import org.opensearch.repositories.RepositoriesService;
+import org.opensearch.threadpool.TestThreadPool;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.TransportService;
 
@@ -121,7 +122,8 @@ public void start(
                     ),
                     settings,
                     new ClusterSettings(settings, ClusterSettings.BUILT_IN_CLUSTER_SETTINGS),
-                    () -> 0L
+                    () -> 0L,
+                    new TestThreadPool(getClass().getName())
                 );
             } else {
                 return null;