Skip to content

Commit

Permalink
Replacing hardcoded prefix for remote_store in tests.
Browse files Browse the repository at this point in the history
Signed-off-by: Swetha Guptha <[email protected]>
  • Loading branch information
Swetha Guptha committed Oct 20, 2024
1 parent fde03d6 commit 53ccacb
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -39,8 +39,8 @@ public class RemoteStoreNodeAttribute {

public static final List<String> REMOTE_STORE_NODE_ATTRIBUTE_KEY_PREFIX = List.of("remote_store", "remote_publication");
public static final String REMOTE_STORE_CLUSTER_STATE_REPOSITORY_NAME_ATTRIBUTE_KEY = "remote_publication.state.repository";
public static final String REMOTE_STORE_SEGMENT_REPOSITORY_NAME_ATTRIBUTE_KEY = "remote_store.segment.repository";
public static final String REMOTE_STORE_TRANSLOG_REPOSITORY_NAME_ATTRIBUTE_KEY = "remote_store.translog.repository";
public static final String REMOTE_STORE_SEGMENT_REPOSITORY_NAME_ATTRIBUTE_KEY = "remote_publication.segment.repository";
public static final String REMOTE_STORE_TRANSLOG_REPOSITORY_NAME_ATTRIBUTE_KEY = "remote_publication.translog.repository";
public static final String REMOTE_STORE_ROUTING_TABLE_REPOSITORY_NAME_ATTRIBUTE_KEY = "remote_publication.routing_table.repository";

public static final List<String> REMOTE_CLUSTER_STATE_REPOSITORY_NAME_ATTRIBUTE_KEYS = REMOTE_STORE_NODE_ATTRIBUTE_KEY_PREFIX.stream()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1060,7 +1060,7 @@ public void testIsOnRemoteNode() {
.put(IndexMetadata.SETTING_VERSION_CREATED, version)
.put(IndexMetadata.SETTING_INDEX_UUID, "0xdeadbeef")
.build();
Settings nodeSettings = Settings.builder().put("node.attr.remote_store.translog.repository", "my-repo-1").build();
Settings nodeSettings = Settings.builder().put("node.attr.remote_publication.translog.repository", "my-repo-1").build();
IndexSettings settings = newIndexSettings(newIndexMeta("index", theSettings), nodeSettings);
assertTrue("Index should be on remote node", settings.isAssignedOnRemoteNode());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public static IndexSettings createIndexSettings(boolean remote, Settings setting
if (remote) {
Settings nodeSettings = Settings.builder()
.put("node.name", "xyz")
.put("node.attr.remote_store.translog.repository", "seg_repo")
.put("node.attr.remote_publication.translog.repository", "seg_repo")
.build();
indexSettings = IndexSettingsModule.newIndexSettings(new Index("test_index", "_na_"), settings, nodeSettings);
} else {
Expand Down

0 comments on commit 53ccacb

Please sign in to comment.