Address review comments

alexey-ivanov-es · alexey-ivanov-es · commit 8b7f1f53a71d · 2025-04-08T18:35:19.000+01:00
diff --git a/docs/changelog/126409.yaml b/docs/changelog/126409.yaml
@@ -1,4 +1,4 @@
-pr: 124884
+pr: 126409
 summary: System data streams are not being upgraded in the feature migration API
 area: Infra/Core
 type: bug
diff --git a/x-pack/plugin/migrate/src/main/java/org/elasticsearch/system_indices/task/SystemIndexMigrator.java b/x-pack/plugin/migrate/src/main/java/org/elasticsearch/system_indices/task/SystemIndexMigrator.java
@@ -196,15 +196,15 @@ public void run(SystemIndexMigrationTaskState taskState) {
                         markAsFailed(
                             new IllegalStateException(
                                 format(
-                                    "failed to resume system index migration from resource [%s], that is not present in the cluster",
+                                    "failed to resume system resource migration from resource [%s], that is not present in the cluster",
                                     stateIndexName
                                 )
                             )
                         );
                     }
                     logger.warn(
                         () -> format(
-                            "resuming system index migration with resource [%s],"
+                            "resuming system resource migration with resource [%s],"
                                 + " which does not match resource given in last task state [%s]",
                             nextMigrationInfo.getCurrentResourceName(),
                             stateIndexName

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-pr: 124884`
	`1`	`+pr: 126409`
`2`	`2`	`summary: System data streams are not being upgraded in the feature migration API`
`3`	`3`	`area: Infra/Core`
`4`	`4`	`type: bug`
Original file line number	Diff line number	Diff line change
`@@ -196,15 +196,15 @@ public void run(SystemIndexMigrationTaskState taskState) {`
`196`	`196`	`markAsFailed(`
`197`	`197`	`new IllegalStateException(`
`198`	`198`	`format(`
`199`		`- "failed to resume system index migration from resource [%s], that is not present in the cluster",`
	`199`	`+ "failed to resume system resource migration from resource [%s], that is not present in the cluster",`
`200`	`200`	`stateIndexName`
`201`	`201`	`)`
`202`	`202`	`)`
`203`	`203`	`);`
`204`	`204`	`}`
`205`	`205`	`logger.warn(`
`206`	`206`	`() -> format(`
`207`		`- "resuming system index migration with resource [%s],"`
	`207`	`+ "resuming system resource migration with resource [%s],"`
`208`	`208`	`+ " which does not match resource given in last task state [%s]",`
`209`	`209`	`nextMigrationInfo.getCurrentResourceName(),`
`210`	`210`	`stateIndexName`