@@ -156,29 +156,30 @@ protected ClusterBlockException checkBlock(RolloverRequest request, ClusterState
156156 );
157157 ResolvedExpression resolvedRolloverTarget = SelectorResolver .parseExpression (request .getRolloverTarget (), request .indicesOptions ());
158158 final IndexAbstraction indexAbstraction = state .metadata ().getIndicesLookup ().get (resolvedRolloverTarget .resource ());
159+ final String [] indicesToCheck ;
159160 if (indexAbstraction .getType ().equals (IndexAbstraction .Type .DATA_STREAM )) {
160161 DataStream dataStream = (DataStream ) indexAbstraction ;
161162 boolean targetFailureStore = resolvedRolloverTarget .selector () != null
162163 && resolvedRolloverTarget .selector ().shouldIncludeFailures ();
163- String indexToCheck ;
164164 if (targetFailureStore == false ) {
165- indexToCheck = dataStream .getWriteIndex ().getName ();
165+ assert dataStream .getWriteIndex () != null : dataStream .getName () + " is a data stream but has no write index" ;
166+ assert dataStream .getWriteIndex ().getName () != null
167+ : dataStream .getName () + " is a data stream but the write index is null" ;
168+ indicesToCheck = new String [] { dataStream .getWriteIndex ().getName () };
166169 } else if (dataStream .getWriteFailureIndex () != null ) {
167- indexToCheck = dataStream .getWriteFailureIndex ().getName ();
170+ assert dataStream .getWriteFailureIndex ().getName () != null
171+ : "the write index for the data stream " + dataStream .getName () + " is null" ;
172+ indicesToCheck = new String [] { dataStream .getWriteFailureIndex ().getName () };
168173 } else {
169- indexToCheck = null ;
170- }
171- if (indexToCheck == null ) {
172- return null ;
173- } else {
174- return state .blocks ().indicesBlockedException (ClusterBlockLevel .METADATA_WRITE , new String [] { indexToCheck });
174+ indicesToCheck = null ;
175175 }
176176 } else {
177- return state .blocks ()
178- .indicesBlockedException (
179- ClusterBlockLevel .METADATA_WRITE ,
180- indexNameExpressionResolver .concreteIndexNames (state , indicesOptions , request )
181- );
177+ indicesToCheck = indexNameExpressionResolver .concreteIndexNames (state , indicesOptions , request );
178+ }
179+ if (indicesToCheck == null ) {
180+ return null ;
181+ } else {
182+ return state .blocks ().indicesBlockedException (ClusterBlockLevel .METADATA_WRITE , indicesToCheck );
182183 }
183184 }
184185
0 commit comments