6868import org .elasticsearch .transport .TransportService ;
6969
7070import java .util .ArrayList ;
71- import java .util .Arrays ;
7271import java .util .HashMap ;
7372import java .util .HashSet ;
7473import java .util .Iterator ;
@@ -205,8 +204,8 @@ private void executeIngestAndBulk(Task task, final BulkRequest bulkRequest, fina
205204 final ActionListener <BulkResponse > listener , final AtomicArray <BulkItemResponse > responses ,
206205 Map <String , IndexNotFoundException > indicesThatCannotBeCreated ) {
207206 boolean hasIndexRequestsWithPipelines = false ;
208- final ClusterState state = clusterService .state ();
209- ImmutableOpenMap <String , IndexMetaData > indicesMetaData = state . getMetaData () .indices ();
207+ final MetaData metaData = clusterService .state (). metaData ();
208+ ImmutableOpenMap <String , IndexMetaData > indicesMetaData = metaData .indices ();
210209 for (DocWriteRequest <?> actionRequest : bulkRequest .requests ) {
211210 if (actionRequest instanceof IndexRequest ) {
212211 IndexRequest indexRequest = (IndexRequest ) actionRequest ;
@@ -215,7 +214,7 @@ private void executeIngestAndBulk(Task task, final BulkRequest bulkRequest, fina
215214 IndexMetaData indexMetaData = indicesMetaData .get (indexRequest .index ());
216215 if (indexMetaData == null ) {
217216 //check the alias
218- AliasOrIndex indexOrAlias = state . metaData () .getAliasAndIndexLookup ().get (indexRequest .index ());
217+ AliasOrIndex indexOrAlias = metaData .getAliasAndIndexLookup ().get (indexRequest .index ());
219218 if (indexOrAlias != null && indexOrAlias .isAlias ()) {
220219 AliasOrIndex .Alias alias = (AliasOrIndex .Alias ) indexOrAlias ;
221220 indexMetaData = alias .getWriteIndex ();
0 commit comments