adding a check for nonexistent failure store

masseyke · masseyke · commit fb78a5308b79 · 2025-02-18T17:40:07.000-06:00
diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java b/server/src/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java
@@ -165,7 +165,7 @@ protected ClusterBlockException checkBlock(RolloverRequest request, ClusterState
             if (targetData) {
                 indicesToCheck.add(dataStream.getWriteIndex().getName());
             }
-            if (targetFailureStore) {
+            if (targetFailureStore && dataStream.getWriteFailureIndex() != null) {
                 indicesToCheck.add(dataStream.getWriteFailureIndex().getName());
             }
             return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE, indicesToCheck.toArray(new String[0]));

Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,7 @@ protected ClusterBlockException checkBlock(RolloverRequest request, ClusterState`
`165`	`165`	`if (targetData) {`
`166`	`166`	`indicesToCheck.add(dataStream.getWriteIndex().getName());`
`167`	`167`	`}`
`168`		`- if (targetFailureStore) {`
	`168`	`+ if (targetFailureStore && dataStream.getWriteFailureIndex() != null) {`
`169`	`169`	`indicesToCheck.add(dataStream.getWriteFailureIndex().getName());`
`170`	`170`	`}`
`171`	`171`	`return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE, indicesToCheck.toArray(new String[0]));`