14
14
import org .opensearch .remotemigration .MigrationBaseTestCase ;
15
15
import org .opensearch .remotestore .multipart .mocks .MockFsRepositoryPlugin ;
16
16
import org .opensearch .repositories .blobstore .BlobStoreRepository ;
17
+ import org .opensearch .repositories .fs .FsRepository ;
17
18
import org .opensearch .repositories .fs .ReloadableFsRepository ;
18
19
import org .opensearch .test .InternalSettingsPlugin ;
19
20
import org .opensearch .test .OpenSearchIntegTestCase ;
@@ -115,7 +116,7 @@ public Settings.Builder remoteWithRoutingTableNodeSetting() {
115
116
segmentRepoPath ,
116
117
REPOSITORY_2_NAME ,
117
118
translogRepoPath ,
118
- REPOSITORY_NAME ,
119
+ ROUTING_TABLE_REPO_NAME ,
119
120
segmentRepoPath ,
120
121
false
121
122
)
@@ -186,6 +187,7 @@ public void testRemoteNodeWithRoutingTableJoinRemoteCluster() throws Exception {
186
187
internalCluster ().startDataOnlyNodes (2 );
187
188
setAddRemote (false );
188
189
190
+
189
191
ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest ();
190
192
updateSettingsRequest .persistentSettings (
191
193
Settings .builder ()
@@ -196,6 +198,7 @@ public void testRemoteNodeWithRoutingTableJoinRemoteCluster() throws Exception {
196
198
197
199
// Remote Repo with Routing table
198
200
Settings settings = remoteWithRoutingTableNodeSetting ().build ();
201
+
199
202
internalCluster ().startClusterManagerOnlyNode (settings );
200
203
ensureStableCluster (4 );
201
204
ensureGreen ();
@@ -285,10 +288,13 @@ public void testRemoteNodeWithRoutingTableJoiningPublishConfigCluster() throws E
285
288
buildRemoteStoreNodeAttributes (
286
289
REPOSITORY_NAME ,
287
290
segmentRepoPath ,
291
+ ReloadableFsRepository .TYPE ,
288
292
REPOSITORY_2_NAME ,
289
293
translogRepoPath ,
294
+ FsRepository .TYPE ,
290
295
ROUTING_TABLE_REPO_NAME ,
291
296
segmentRepoPath ,
297
+ ReloadableFsRepository .TYPE ,
292
298
false
293
299
)
294
300
)
0 commit comments