Update server/src/main/java/org/elasticsearch/action/admin/indices/mapping/put/TransportPutMappingAction.java

jbaiera · gmarouli · web-flow · commit 3ef3e8a6735c · 2024-12-18T15:19:49.000-05:00
Co-authored-by: Mary Gouseti &lt;mgouseti@gmail.com&gt;
diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/mapping/put/TransportPutMappingAction.java b/server/src/main/java/org/elasticsearch/action/admin/indices/mapping/put/TransportPutMappingAction.java
@@ -195,7 +195,7 @@ static String checkForFailureStoreViolations(ClusterState clusterState, Index[]
             IndexAbstraction indexAbstraction = indicesLookup.get(index.getName());
             if (indexAbstraction != null) {
                 DataStream maybeDataStream = indexAbstraction.getParentDataStream();
-                if (maybeDataStream != null && maybeDataStream.getFailureIndices().containsIndex(index.getName())) {
+                if (maybeDataStream != null && maybeDataStream.isFailureStoreIndex(index.getName())) {
                     violations.add(index.getName());
                 }
             }

Original file line number	Diff line number	Diff line change
`@@ -195,7 +195,7 @@ static String checkForFailureStoreViolations(ClusterState clusterState, Index[]`
`195`	`195`	`IndexAbstraction indexAbstraction = indicesLookup.get(index.getName());`
`196`	`196`	`if (indexAbstraction != null) {`
`197`	`197`	`DataStream maybeDataStream = indexAbstraction.getParentDataStream();`
`198`		`- if (maybeDataStream != null && maybeDataStream.getFailureIndices().containsIndex(index.getName())) {`
	`198`	`+ if (maybeDataStream != null && maybeDataStream.isFailureStoreIndex(index.getName())) {`
`199`	`199`	`violations.add(index.getName());`
`200`	`200`	`}`
`201`	`201`	`}`