33org/elasticsearch/indices/recovery/RecoverySource$1java/lang/Object5org/elasticsearch/index/engine/Engine$RecoveryHandlerRecoverySource.java1org/elasticsearch/indices/recovery/RecoverySourcerecoverp(Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;)Lorg/elasticsearch/indices/recovery/RecoveryResponse; 5org/elasticsearch/indices/recovery/RecoverySource$1$3 5org/elasticsearch/indices/recovery/RecoverySource$1$25org/elasticsearch/indices/recovery/RecoverySource$1$14org/elasticsearch/index/store/Store$MetadataSnapshot#org/elasticsearch/index/store/StoreMetadataSnapshot0org/elasticsearch/index/store/Store$RecoveryDiff RecoveryDiff2org/elasticsearch/index/translog/Translog$Snapshot)org/elasticsearch/index/translog/TranslogSnapshotQorg/elasticsearch/cluster/action/index/MappingUpdatedAction$MappingUpdateListener ;org/elasticsearch/cluster/action/index/MappingUpdatedAction"MappingUpdateListener3org/elasticsearch/index/translog/Translog$Operation% Operation%org/elasticsearch/index/engine/Engine(RecoveryHandler8org/elasticsearch/transport/TransportRequestOptions$Type+3org/elasticsearch/transport/TransportRequestOptions-Type val$shard:Lorg/elasticsearch/index/shard/service/InternalIndexShard; val$request9Lorg/elasticsearch/indices/recovery/StartRecoveryRequest; val$response5Lorg/elasticsearch/indices/recovery/RecoveryResponse;val$indexService.Lorg/elasticsearch/index/service/IndexService;this$03Lorg/elasticsearch/indices/recovery/RecoverySource; (Lorg/elasticsearch/indices/recovery/RecoverySource;Lorg/elasticsearch/index/shard/service/InternalIndexShard;Lorg/elasticsearch/indices/recovery/StartRecoveryRequest;Lorg/elasticsearch/indices/recovery/RecoveryResponse;Lorg/elasticsearch/index/service/IndexService;)V 89 < 01 > 23 @ 45 B 67 D()V :F Gthis5Lorg/elasticsearch/indices/recovery/RecoverySource$1;phase1?(Lorg/elasticsearch/index/deletionpolicy/SnapshotIndexCommit;)V(org/elasticsearch/ElasticsearchExceptionMjava/lang/ThrowableO8org/elasticsearch/index/shard/service/InternalIndexShardQstore'()Lorg/elasticsearch/index/store/Store; ST RUincRef WF X"org/elasticsearch/common/StopWatchZ [Gstart&()Lorg/elasticsearch/common/StopWatch; ]^ [_ getMetadata](Lorg/apache/lucene/index/IndexCommit;)Lorg/elasticsearch/index/store/Store$MetadataSnapshot; ab c:org/elasticsearch/index/deletionpolicy/SnapshotIndexCommitegetFiles()[Ljava/lang/String; gh fi[Ljava/lang/String;kgetE(Ljava/lang/String;)Lorg/elasticsearch/index/store/StoreFileMetaData; mn o access$000`(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/logging/ESLogger; qr s8Snapshot differs from actual index for file: {} meta: {}uasMap()Ljava/util/Map; wx y)org/elasticsearch/common/logging/ESLogger{info((Ljava/lang/String;[Ljava/lang/Object;)V }~ |-org/apache/lucene/index/CorruptIndexExceptionjava/lang/StringBuilder GJSnapshot differs from actual index - maybe index was removed metadata has append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  java/util/Mapsize()I (I)Ljava/lang/StringBuilder;  filestoString()Ljava/lang/String; (Ljava/lang/String;)V : 7org/elasticsearch/indices/recovery/StartRecoveryRequest existingFiles x (Ljava/util/Map;)V :  recoveryDiffj(Lorg/elasticsearch/index/store/Store$MetadataSnapshot;)Lorg/elasticsearch/index/store/Store$RecoveryDiff;  identicalLjava/util/List; java/util/Listiterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next()Ljava/lang/Object; /org/elasticsearch/index/store/StoreFileMetaData3org/elasticsearch/indices/recovery/RecoveryResponsephase1ExistingFileNames name add(Ljava/lang/Object;)Z phase1ExistingFileSizes length()J java/lang/LongvalueOf(J)Ljava/lang/Long;  access$100 r isTraceEnabled | access$200 r m[{}][{}] recovery [phase1] to {}: not recovering [{}], exists in local store and has checksum [{}], size [{}]shardId)()Lorg/elasticsearch/index/shard/ShardId; %org/elasticsearch/index/shard/ShardIdindex!()Lorg/elasticsearch/index/Index; org/elasticsearch/index/Index id java/lang/Integer(I)Ljava/lang/Integer;  targetNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; checksum trace ~ | different  missing  *org/elasticsearch/common/collect/Iterables concat>(Ljava/lang/Iterable;Ljava/lang/Iterable;)Ljava/lang/Iterable;     java/lang/Iterable  containsKey   access$300 r s[{}][{}] recovery [phase1] to {}: recovering [{}], exists in local store, but is different: remote [{}], local [{}]&(Ljava/lang/Object;)Ljava/lang/Object; m  access$400 r L[{}][{}] recovery [phase1] to {}: recovering [{}], does not exists in remote phase1FileNames " #phase1FileSizes % &phase1TotalSizeJ () *phase1ExistingTotalSize ,) - access$500 /r 0u[{}][{}] recovery [phase1] to {}: recovering_files [{}] with total_size [{}], reusing_files [{}] with total_size [{}]2 +org/elasticsearch/common/unit/ByteSizeValue5(J)V :7 68;org/elasticsearch/indices/recovery/RecoveryFilesInfoRequest: recoveryId < =m(JLorg/elasticsearch/index/shard/ShardId;Ljava/util/List;Ljava/util/List;Ljava/util/List;Ljava/util/List;JJ)V :? ;@ access$700c(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/transport/TransportService; BC D'internal:index/shard/recovery/filesInfoFoptions7()Lorg/elasticsearch/transport/TransportRequestOptions; HI .J access$600^(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/common/unit/TimeValue; LM N withTimeout`(Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/transport/TransportRequestOptions; PQ .R9org/elasticsearch/transport/EmptyTransportResponseHandlerT INSTANCE_SAME;Lorg/elasticsearch/transport/EmptyTransportResponseHandler; VW UX,org/elasticsearch/transport/TransportServiceZ submitRequest(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequest;Lorg/elasticsearch/transport/TransportRequestOptions;Lorg/elasticsearch/transport/TransportResponseHandler;)Lorg/elasticsearch/transport/TransportFuture; \] [^+org/elasticsearch/transport/TransportFuture`txGet b ac#java/util/concurrent/CountDownLatche(I)V :g fh)java/util/concurrent/CopyOnWriteArrayListj kG+java/util/concurrent/atomic/AtomicReferencem nGjava/lang/Stringp(I)Ljava/lang/Object; mr s longValue u v access$800j(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/indices/recovery/RecoverySettings; xy z3org/elasticsearch/indices/recovery/RecoverySettings|SMALL_FILE_CUTOFF_BYTES ~) }concurrentStreamPool+()Ljava/util/concurrent/ThreadPoolExecutor;  }concurrentSmallFileStreamPool  }'java/util/concurrent/ThreadPoolExecutor"(Lorg/elasticsearch/indices/recovery/RecoverySource$1;Lorg/elasticsearch/index/store/Store;Lorg/elasticsearch/index/store/Store$MetadataSnapshot;Ljava/lang/String;Ljava/util/concurrent/atomic/AtomicReference;Ljava/util/concurrent/CopyOnWriteArrayList;Ljava/util/concurrent/CountDownLatch;)V : execute(Ljava/lang/Runnable;)V  await F f m n"org/elasticsearch/ExceptionsHelperrethrowAndSuppress(Ljava/util/List;)V  %org/elasticsearch/common/collect/Sets newHashSet(([Ljava/lang/Object;)Ljava/util/HashSet;  )internal:index/shard/recovery/clean_files;+Ljava/util/concurrent/CopyOnWriteArrayList;corruptedEngine^Ljava/util/concurrent/atomic/AtomicReference;-Ljava/util/concurrent/atomic/AtomicReference; fileIndex snapshotFiles#Ljava/util/Set;Ljava/util/Set;eLjava/lang/Throwable;snapshot{} recovery [phase2] to {}: updating current mapping to masterupdateMappingOnMaster F  access$1500 r >{} recovery [phase2] to {}: sending transaction log operations sendSnapshot7(Lorg/elasticsearch/index/translog/Translog$Snapshot;)I    access$1600 "r #%{} recovery [phase2] to {}: took [{}]% phase2Time ') (phase2Operations * +4Lorg/elasticsearch/index/translog/Translog$Snapshot;totalOperationsjava/lang/InterruptedException/>org/elasticsearch/common/util/concurrent/ConcurrentCollections1newBlockingQueue&()Ljava/util/concurrent/BlockingQueue; 34 25 access$1700_(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/cluster/ClusterService; 78 9recovery_mapping_check;(Lorg/elasticsearch/indices/recovery/RecoverySource$1;Ljava/util/concurrent/CountDownLatch;Ljava/util/concurrent/BlockingQueue;)V := >(org/elasticsearch/cluster/ClusterService@submitStateUpdateTaskG(Ljava/lang/String;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V BC AD"java/util/concurrent/BlockingQueueFjava/lang/ThreadH currentThread()Ljava/lang/Thread; JK IL interrupt NF IOisEmpty Q GR G](Lorg/elasticsearch/indices/recovery/RecoverySource$1;Ljava/util/concurrent/CountDownLatch;)V :U V G-org/elasticsearch/index/mapper/DocumentMapperY access$2000r(Lorg/elasticsearch/indices/recovery/RecoverySource;)Lorg/elasticsearch/cluster/action/index/MappingUpdatedAction; [\ ],org/elasticsearch/index/service/IndexService_ `getName b c indexUUID e `f(Ljava/lang/String;Lorg/elasticsearch/index/mapper/DocumentMapper;Ljava/lang/String;Lorg/elasticsearch/cluster/action/index/MappingUpdatedAction$MappingUpdateListener;)V h #ijava/util/concurrent/TimeUnitk MILLISECONDSLjava/util/concurrent/TimeUnit; mn lo#(JLjava/util/concurrent/TimeUnit;)Z q fr access$2100 tr uT{} recovery [phase2] to {}: waiting on pending mapping update timed out. waited [{}]wdebug y~ |z access$2200 |r }9interrupted while waiting for mapping to update on master Ljava/lang/InterruptedException;documentMapper/Lorg/elasticsearch/index/mapper/DocumentMapper;documentMappersToUpdateULjava/util/concurrent/BlockingQueue;$Ljava/util/concurrent/BlockingQueue;updatedOnMasterlistenerSLorg/elasticsearch/cluster/action/index/MappingUpdatedAction$MappingUpdateListener;phase3=org/elasticsearch/index/shard/IllegalIndexShardStateException access$2300 r D[{}][{}] recovery [phase3] to {}: sending transaction log operations&internal:index/shard/recovery/finalizeBorg/elasticsearch/indices/recovery/RecoveryFinalizeRecoveryRequest  access$2400 M markAsRelocated  to -(Ljava/lang/Object;)Ljava/lang/StringBuilder;   relocatedN(Ljava/lang/String;)Lorg/elasticsearch/index/shard/service/InternalIndexShard;  R access$2500 r +[{}][{}] recovery [phase3] to {}: took [{}] phase3Time ) phase3Operations  ?Lorg/elasticsearch/index/shard/IllegalIndexShardStateException;&org/elasticsearch/common/collect/Lists newArrayList()Ljava/util/ArrayList;  7()Lorg/elasticsearch/index/translog/Translog$Operation;   estimateSize  & translogOps  } translogSize/()Lorg/elasticsearch/common/unit/ByteSizeValue;  }bytes  6Dorg/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest;(JLorg/elasticsearch/index/shard/ShardId;Ljava/util/List;)V : *internal:index/shard/recovery/translog_opscompress  } withCompress8(Z)Lorg/elasticsearch/transport/TransportRequestOptions;  .RECOVERY:Lorg/elasticsearch/transport/TransportRequestOptions$Type;  ,withTypeq(Lorg/elasticsearch/transport/TransportRequestOptions$Type;)Lorg/elasticsearch/transport/TransportRequestOptions;  .clear F  RtranslogOperationsRequestFLorg/elasticsearch/indices/recovery/RecoveryTranslogOperationsRequest;ops operationsGLjava/util/List; operation5Lorg/elasticsearch/index/translog/Translog$Operation;CodeLocalVariableTableLineNumberTableLocalVariableTypeTable StackMapTable Exceptions SourceFileEnclosingMethod InnerClasses 0123456789:;J *+=*,?*-A*C*E*H  IJKLj 0 A 7*?V:Y[Y\`:+d:+j:  6 6   f  2:  p:  K*=tvY SYzSYYz Y*A:  :   : *C ǹW*C ҸعW a7*=۹[*=Y*ASY*ASY*ASY SY SY ҸS  aAJ  :   : *A ǹe*=Y*ASY*ASY*ASY SY*A ǹSY SH*=!Y*ASY*ASY*ASY S*C$ ǹW*C' ҸعW  aA*C +*C.*=13Y*ASY*ASY*ASY*C$4SY6Y 9SY*CĹ4SY6Y9S;Y*A>*A*C$*C'*C*C*C+*C.A: *=E*AG K*=OSY_dWfY*C$4i: kYl: nYo: 6*C$:pq:*C'tԶw7*={W*={:*={:Y*        +j:*=E*AY*A>*?K*=OSY_dWW*=Y*ASY*ASY*ASYS*C4:Y*A*C$46Y 9ſ:P%'%$LM CV -rk 2m 5j      H)^w'B \ Y P G D[%0IJ0.)+)"S P G [='CLQpnvy^p\ 147<DM R [%/5 f[lc  D1/f[;fknKq  f[;fknfPfP N*?Y*A*=Y*ASY*AS[Y\`M*=E*AY*A>*AK*=OSY_dW,W*C, *=Y*ASY*ASY*ASY,S*=Y*ASY*AS**=Y*ASY*AS[Y\`M*+!>,W*=$&Y*ASY*ASY,S*C,)*C,*IJ-N7;J.J C N!"#$'(**+5,;-@.n/|01NF6LfYiM*=:<Y*,+?E, NMP+SfY+TiNY*-W:+X:5Z:*=^*Ead*Egj-*=Ops4*=vxY*ASY*ASY*=OS{:MP*=~{&*-00\ .u#_<IJ LW V78 9&Z*]-[.\4^=_>aLbWnuoprsxuvwz.-Gf0 f!;DB0:*?Y*A*=Y*ASY*ASY*AS[Y\`M*+!>*=E*AY*A>*AK*=SY_dW*A**?Y*AW:,W*=Y*ASY*ASY*ASY,S*C,*C4:IJ:-dj.> Ydj#19[NM B= B6:+:*?Y*AW!aB*={!*={ĶǔfY*A>*A:*=E*AK*={Ѷղٶ*=SY_dW= B+::[Y*A>*A:*=E*AK*={Ѷղٶ*=SY_dW\ J?BIJB-@>);. 6.  6^ &5?BLOo?!& 9b aN Z  !#$ &' )* ,./@