Skip to content

Commit

Permalink
Set repo prefix to remote_store in RemotePublicationConfigurationIT.
Browse files Browse the repository at this point in the history
Signed-off-by: Swetha Guptha <gupthasg@amazon.com>
  • Loading branch information
Swetha Guptha committed Oct 22, 2024
1 parent 49b45cc commit 7690805
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ public void setUp() throws Exception {
}

public Settings.Builder remotePublishConfiguredNodeSetting() {
String remoteStoreNodeAttributePrefix = "remote_publication";
String remoteStoreNodeAttributePrefix = "remote_store";
String stateRepoSettingsAttributeKeyPrefix = String.format(
Locale.getDefault(),
"node.attr." + REPOSITORY_SETTINGS_ATTRIBUTE_KEY_PREFIX,
Expand All @@ -92,12 +92,12 @@ public Settings.Builder remotePublishConfiguredNodeSetting() {
);

Settings.Builder builder = Settings.builder()
.put("node.attr." + "remote_publication.state.repository", REPOSITORY_NAME)
.put("node.attr." + "remote_store.state.repository", REPOSITORY_NAME)
.put(stateRepoTypeAttributeKey, ReloadableFsRepository.TYPE)
.put(stateRepoSettingsAttributeKeyPrefix + "location", segmentRepoPath)
.put(stateRepoSettingsAttributeKeyPrefix + prefixModeVerificationSuffix, true)
.put(REMOTE_CLUSTER_STATE_ENABLED_SETTING.getKey(), true)
.put("node.attr." + "remote_publication.routing_table.repository", ROUTING_TABLE_REPO_NAME)
.put("node.attr." + "remote_store.routing_table.repository", ROUTING_TABLE_REPO_NAME)
.put(routingTableRepoTypeAttributeKey, ReloadableFsRepository.TYPE)
.put(routingTableRepoSettingsAttributeKeyPrefix + "location", segmentRepoPath);
return builder;
Expand Down

0 comments on commit 7690805

Please sign in to comment.