Rmote index name using the remote_ prefix instead of _remote suffix when the convert_index_to_remote operation restored the target index .

liuyongheng · liuyongheng · commit 242e9e54773b · 2025-06-06T14:30:12.000+08:00
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
@@ -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
@@ -113,7 +113,7 @@ class ConvertIndexToRemoteActionIT : IndexStateManagementRestTestCase() {
             )
         }
 
-        val remoteIndexName = "${indexName}_remote"
+        val remoteIndexName = "remote_$indexName"
         waitFor { assertIndexExists(remoteIndexName) }
 
         val isRemote = isIndexRemote(remoteIndexName)

Original file line number	Diff line number	Diff line change
`@@ -113,7 +113,7 @@ class ConvertIndexToRemoteActionIT : IndexStateManagementRestTestCase() {`
`113`	`113`	`)`
`114`	`114`	`}`
`115`	`115`
`116`		`- val remoteIndexName = "${indexName}_remote"`
	`116`	`+ val remoteIndexName = "remote_$indexName"`
`117`	`117`	`waitFor { assertIndexExists(remoteIndexName) }`
`118`	`118`
`119`	`119`	`val isRemote = isIndexRemote(remoteIndexName)`