diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/step/restore/AttemptRestoreStep.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/step/restore/AttemptRestoreStep.kt index 1038d7238..83b40f986 100644 --- a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/step/restore/AttemptRestoreStep.kt +++ b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/step/restore/AttemptRestoreStep.kt @@ -91,7 +91,7 @@ class AttemptRestoreStep(private val action: ConvertIndexToRemoteAction) : Step( .indices(indexName) .storageType(RestoreSnapshotRequest.StorageType.REMOTE_SNAPSHOT) .renamePattern("^(.*)\$") - .renameReplacement("$1_remote") + .renameReplacement("remote_$1") .waitForCompletion(false) val response: RestoreSnapshotResponse = context.client.admin().cluster().suspendUntil { restoreSnapshot(restoreSnapshotRequest, it) diff --git a/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/action/ConvertIndexToRemoteActionIT.kt b/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/action/ConvertIndexToRemoteActionIT.kt index b3dc64de3..49801014b 100644 --- a/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/action/ConvertIndexToRemoteActionIT.kt +++ b/src/test/kotlin/org/opensearch/indexmanagement/indexstatemanagement/action/ConvertIndexToRemoteActionIT.kt @@ -113,7 +113,7 @@ class ConvertIndexToRemoteActionIT : IndexStateManagementRestTestCase() { ) } - val remoteIndexName = "${indexName}_remote" + val remoteIndexName = "remote_$indexName" waitFor { assertIndexExists(remoteIndexName) } val isRemote = isIndexRemote(remoteIndexName)