339org/elasticsearch/cluster/metadata/MetaDataMappingService4org/elasticsearch/common/component/AbstractComponentMetaDataMappingService.javaDorg/elasticsearch/cluster/metadata/MetaDataMappingService$UpdateTask UpdateTaskEorg/elasticsearch/cluster/metadata/MetaDataMappingService$RefreshTask  RefreshTaskEorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask  MappingTask;org/elasticsearch/cluster/metadata/MetaDataMappingService$4;org/elasticsearch/cluster/metadata/MetaDataMappingService$3;org/elasticsearch/cluster/metadata/MetaDataMappingService$2;org/elasticsearch/cluster/metadata/MetaDataMappingService$18org/elasticsearch/cluster/metadata/IndexMetaData$Builder0org/elasticsearch/cluster/metadata/IndexMetaDataBuilderjava/util/Map$Entry java/util/MapEntry3org/elasticsearch/cluster/metadata/MetaData$Builder!+org/elasticsearch/cluster/metadata/MetaData#.org/elasticsearch/cluster/ClusterState$Builder%&org/elasticsearch/cluster/ClusterState' threadPool)Lorg/elasticsearch/threadpool/ThreadPool;clusterService*Lorg/elasticsearch/cluster/ClusterService;indicesService*Lorg/elasticsearch/indices/IndicesService;refreshOrUpdateMutexLjava/lang/Object;refreshOrUpdateQueueLjava/util/List;YLjava/util/List;refreshOrUpdateInsertOrderJ#refreshOrUpdateProcessedInsertOrder(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/indices/IndicesService;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V 7: ;java/lang/Object=()V 7? >@ /0 Bjava/util/ArrayListD E@ 12 G )* I +, K -. Mthis;Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;settings,Lorg/elasticsearch/common/settings/Settings;executeRefreshOrUpdateS(Lorg/elasticsearch/cluster/ClusterState;J)Lorg/elasticsearch/common/collect/Tuple;java/lang/ExceptionUjava/util/ListWisEmpty()Z YZ X[&org/elasticsearch/common/collect/Tuple]tupleN(Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/Tuple; _` ^a 65 caddAll(Ljava/util/Collection;)Z ef Xgclear i? Xj 45 ljava/lang/Throwablen%org/elasticsearch/common/collect/Mapsp newHashMap()Ljava/util/HashMap; rs qtiterator()Ljava/util/Iterator; vw Xxjava/util/IteratorzhasNext |Z {}next()Ljava/lang/Object;  {indexLjava/lang/String; logger+Lorg/elasticsearch/common/logging/ESLogger; 7ignoring a mapping task of type [{}] with a null index.)org/elasticsearch/common/logging/ESLoggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V get&(Ljava/lang/Object;)Ljava/lang/Object; put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; add(Ljava/lang/Object;)Z XmetaData/()Lorg/elasticsearch/cluster/metadata/MetaData; (builderd(Lorg/elasticsearch/cluster/metadata/MetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; $entrySet()Ljava/util/Set;  java/util/Set xgetKey java/lang/StringF(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData; "3[{}] ignoring tasks - index meta data doesn't existgetValue  indexUUID  isSameUUID(Ljava/lang/String;)Z A[{}] ignoring task [{}] - index meta data doesn't match task uuidorder 5 nodeId size()I X(I)Ljava/lang/Object; Xtype equals set'(ILjava/lang/Object;)Ljava/lang/Object; X(org/elasticsearch/indices/IndicesService indexServiceB(Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService; ()Ljava/lang/String; .()Lorg/elasticsearch/common/settings/Settings; Q nodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; (-org/elasticsearch/cluster/node/DiscoveryNodes localNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ,org/elasticsearch/cluster/node/DiscoveryNodeid  createIndex(Ljava/lang/String;Lorg/elasticsearch/common/settings/Settings;Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService; %org/elasticsearch/common/collect/Sets newHashSet()Ljava/util/HashSet; ,org/elasticsearch/index/service/IndexService types[Ljava/lang/String;  java/util/Collections ,(Ljava/util/Collection;[Ljava/lang/Object;)Z e   mappings5()Lorg/elasticsearch/common/collect/ImmutableOpenMap;  1org/elasticsearch/common/collect/ImmutableOpenMap containsKey   mapperService0()Lorg/elasticsearch/index/mapper/MapperService;   2org/elasticsearch/cluster/metadata/MappingMetaDatasource6()Lorg/elasticsearch/common/compress/CompressedString;   ,org/elasticsearch/index/mapper/MapperService"mergex(Ljava/lang/String;Lorg/elasticsearch/common/compress/CompressedString;Z)Lorg/elasticsearch/index/mapper/DocumentMapper; $% #&n(Lorg/elasticsearch/cluster/metadata/IndexMetaData;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; ( )processIndexMappingTasks{(Ljava/util/List;Lorg/elasticsearch/index/service/IndexService;Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;)Z +, -q(Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; / "0created for mapping processing2 removeIndex'(Ljava/lang/String;Ljava/lang/String;)V 45 6Z(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState$Builder; 8 (9g(Lorg/elasticsearch/cluster/metadata/MetaData$Builder;)Lorg/elasticsearch/cluster/ClusterState$Builder; ; &<build*()Lorg/elasticsearch/cluster/ClusterState; >? &@ indexTaskstaskGLorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask;i$Ljava/util/Iterator;eTaskFLorg/elasticsearch/cluster/metadata/MetaDataMappingService$UpdateTask;existingiIuTaskZtypesToIntroduce#Ljava/util/Set;Ljava/util/Set; indexDirty indexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData; allIndexTaskstasks.Lorg/elasticsearch/index/service/IndexService;:Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;entryLjava/util/Map$Entry;>;Ljava/util/Map$Entry; currentState(Lorg/elasticsearch/cluster/ClusterState;insertionOrderallTasks tasksPerIndex|Ljava/util/Map;>;Ljava/util/Map;dirty mdBuilder5Lorg/elasticsearch/cluster/metadata/MetaData$Builder;!()Lorg/elasticsearch/index/Index; e forg/elasticsearch/index/Indexhname j ik&org/elasticsearch/common/collect/Listsm newArrayList()Ljava/util/ArrayList; op nqcontains t udocumentMapperC(Ljava/lang/String;)Lorg/elasticsearch/index/mapper/DocumentMapper; wx #y-org/elasticsearch/index/mapper/DocumentMapper{ mappingSource } |~mappingH(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MappingMetaData;  2org/elasticsearch/common/compress/CompressedString 2(Lorg/elasticsearch/index/mapper/DocumentMapper;)V 7  putMappingp(Lorg/elasticsearch/cluster/metadata/MappingMetaData;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;  :[{}] re-syncing mappings with cluster state for types [{}]warn  ;[{}] failed to refresh-mapping in cluster state, types [{}]4Lorg/elasticsearch/common/compress/CompressedString; } T[{}] update_mapping [{}] ignoring mapping update task as its source is equal to oursf[{}] update_mapping [{}] ignoring mapping update task as it results in the same source as what we haveisDebugEnabled Z 3[{}] update_mapping [{}] (dynamic) with source [{}] isInfoEnabled Z "[{}] update_mapping [{}] (dynamic)info  9[{}] failed to update-mapping in cluster state, type [{}]/illegal state, got wrong mapping task type [{}]mapper/Lorg/elasticsearch/index/mapper/DocumentMapper;arr$len$ updatedTypes$Ljava/util/List;tLjava/lang/Throwable; refreshTaskGLorg/elasticsearch/cluster/metadata/MetaDataMappingService$RefreshTask;mappingMetaData4Lorg/elasticsearch/cluster/metadata/MappingMetaData; updatedMapper updateTaskprocessedRefreshesrefreshMapping:(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V 7 java/lang/StringBuilder @refresh-mapping [append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  ][java/util/ArraystoString'([Ljava/lang/Object;)Ljava/lang/String;  ]  !org/elasticsearch/common/PriorityHIGH#Lorg/elasticsearch/common/Priority;  ?(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;J)V 7 (org/elasticsearch/cluster/ClusterServicesubmitStateUpdateTaskj(Ljava/lang/String;Lorg/elasticsearch/common/Priority;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V   insertOrder updateMapping(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/common/compress/CompressedString;JLjava/lang/String;Lorg/elasticsearch/action/ActionListener;)V 7 'org/elasticsearch/action/ActionListenerupdate-mapping [ ] / node [ ], order [(J)Ljava/lang/StringBuilder;  h(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;Lorg/elasticsearch/action/ActionListener;J)V 7 listenereLorg/elasticsearch/action/ActionListener;)Lorg/elasticsearch/action/ActionListener; removeMapping(Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener;)Vremove-mapping [\org/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest()[Ljava/lang/String;  (Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;Lorg/elasticsearch/cluster/ack/AckedRequest;Lorg/elasticsearch/action/ActionListener;Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest;)V 7 request^Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest;(Lorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener;)V put-mapping [ Vorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest   (Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;Lorg/elasticsearch/cluster/ack/AckedRequest;Lorg/elasticsearch/action/ActionListener;Lorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest;)V 7 XLorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest; access$000h(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;)Lorg/elasticsearch/common/logging/ESLogger;x0 access$100 access$200 access$300g(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;)Lorg/elasticsearch/indices/IndicesService; access$400g(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;)Lorg/elasticsearch/cluster/ClusterService; access$500 access$600 access$700 access$800 access$900 access$1000 access$1100 access$1200 SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotationsLocalVariableTypeTable StackMapTable Exceptions(Lorg/elasticsearch/cluster/ClusterState;J)Lorg/elasticsearch/common/collect/Tuple;>;(Ljava/util/List;Lorg/elasticsearch/index/service/IndexService;Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;)Z(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/common/compress/CompressedString;JLjava/lang/String;Lorg/elasticsearch/action/ActionListener;)V(Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener;)V(Lorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener;)V SourceFile InnerClasses!)*+,-./012$3456578%,*+<*>YAC*EYFH*,J*-L*N&4,OP,QR,)*,+,,-.'IBCJ K%L+M(9ST%EYF:*CY:*H\ +bð *d +bð*HhW*Hk**mdç :\ +bu:y:~f :*>YSX:EYF:WW6+::~:  :  :  *>Y S X: EYF:  y:~ : *>Y SYS6:ǔ6 z  :^:նؙGǔ;3˶ؙ#Ɣ W6   W6*N :*N  +:6: y:~C :չW   W:~=: ! !'W *:* .61W6,*N 37:*N 37q +b+:=Ab&]'9]:Z]]b]Pl&B 'B2TCDmEFTGHcIDJKLHMCDpEF1CDJEF+DEFNP\QM-m 6dRS ^<T2 g3U2 p*4M}VPJW!yXZ  EFOP[\]5 ^2{@_abMcd)H'B3NO^<T3 g3U3 !yXY ^3{@_`'NSy {|}'0:FOWeov{!-6;OR^g%CORU[`jmp}(FIP\ailq*'X>bo {1 -X "{FXX{> (|D(X"{XX{0 {@"Uo(X"{XXo(X"{ +V$,+,%m_6,gl::+y:~: :  : r:  :  6 6   j  2:vN,z:9-! W-YWW  \O*>YSY S6": *>YSY SK.:  :  : - :  0 ! #*>YSY S,  ':  W 3 ! #*>YSY Sg*(*>YSY SY S)**>YSY S-Y W6": *>YSY S*>YS@oo e"oh"o"o&~>bZLv QqK TnEK E2  @ ' .} 6 x $  !H 1(CDAEF_OP_U2_V_W\bMQLP) E _U3LO'319@E b n q ~  !" $'%.'6(H)e*h-x.123789:=>A"?$@ABDCYE\F*X{8X{  Xs|+   X{  oV X{ N|0% X{ o$-%!u*CY:*Ym a]m7*H Y+,-Wç :*LYĶ+ʶ-жҶȶԲڻY*ݹ,//4/&4uOPuuu`5'NOP)Q7Rto*0/s>os% *CY: *Ym a]m7 *HY+,-W ç :   *LY+ʶ-ҶȶԲڻY* 477<7&\ OP}5}5 ) 'stu1v?w*D7 >o $.% 8*LY+жҶȶԲڻY*+,+& 8OP88) 8' 7$/% 5*LY +ҶȶԲڻY*+,+& 5OP55) 5' 4T$0%/*& P';%/*& P';%/*& P';%/*N& P';%/*L& P';%/*& P';%/*& P';%/*& P';%/*& P'; %/*& P';!%/*& P';"%/*& P';#%/*& P';12Z       "$ &(