3 \ \ \ \ \                  ^ \ \ \ \  \ \ \ \   \ ! ("#$ ,%& +' \( +)*+ 3,- \./0 812 \3 +45 67 +8 \9:; A<=>? E@AB \CDE FG HIJKL M NO N8P UQRST UV  WX YZ[\]FailedOp InnerClasses^StatStatsOverseerThreadClusterStateUpdater_ LeaderStatusQUEUE_OPERATIONLjava/lang/String; ConstantValue` DELETECOREaREMOVECOLLECTIONb REMOVESHARDcADD_ROUTING_RULEdREMOVE_ROUTING_RULEeSTATEfQUITgSTATE_UPDATE_DELAYI CREATESHARDhUPDATESHARDSTATEilogLorg/slf4j/Logger;lastUpdatedTimeJccThread/Lorg/apache/solr/cloud/Overseer$OverseerThread; updaterThread arfoThreadreader,Lorg/apache/solr/common/cloud/ZkStateReader; shardHandler0Lorg/apache/solr/handler/component/ShardHandler;updateShardHandler+Lorg/apache/solr/update/UpdateShardHandler; adminPathoverseerCollectionProcessor3Lorg/apache/solr/cloud/OverseerCollectionProcessor; zkController$Lorg/apache/solr/cloud/ZkController;stats&Lorg/apache/solr/cloud/Overseer$Stats;idclosedZconfig!Lorg/apache/solr/core/ConfigSolr; getShardNames&(Ljava/lang/Integer;Ljava/util/List;)VCodeLineNumberTableLocalVariableTable sliceNamei numShardsLjava/lang/Integer; shardNamesLjava/util/List;LocalVariableTypeTable$Ljava/util/List; StackMapTable Signature:(Ljava/lang/Integer;Ljava/util/List;)V%(Ljava/util/List;Ljava/lang/String;)Vsarr$[Ljava/lang/String;len$i$shardsj9(Ljava/util/List;Ljava/lang/String;)V(Lorg/apache/solr/handler/component/ShardHandler;Lorg/apache/solr/update/UpdateShardHandler;Ljava/lang/String;Lorg/apache/solr/common/cloud/ZkStateReader;Lorg/apache/solr/cloud/ZkController;Lorg/apache/solr/core/ConfigSolr;)Vthis Lorg/apache/solr/cloud/Overseer; Exceptionsstart(Ljava/lang/String;)VtgLjava/lang/ThreadGroup;ccTgohcfTgautoReplicaFailoverThread9Lorg/apache/solr/cloud/OverseerAutoReplicaFailoverThread;getUpdaterThread1()Lorg/apache/solr/cloud/Overseer$OverseerThread;close()VdoClose getInQueueU(Lorg/apache/solr/common/cloud/SolrZkClient;)Lorg/apache/solr/cloud/DistributedQueue;zkClient+Lorg/apache/solr/common/cloud/SolrZkClient;{(Lorg/apache/solr/common/cloud/SolrZkClient;Lorg/apache/solr/cloud/Overseer$Stats;)Lorg/apache/solr/cloud/DistributedQueue;zkStatsgetInternalQueue getRunningMapS(Lorg/apache/solr/common/cloud/SolrZkClient;)Lorg/apache/solr/cloud/DistributedMap;getCompletedMap getFailureMapgetCollectionQueuecreateOverseerNode.(Lorg/apache/solr/common/cloud/SolrZkClient;)VeNodeExistsException:Lorg/apache/zookeeper/KeeperException$NodeExistsException; Ljava/lang/InterruptedException;&Lorg/apache/zookeeper/KeeperException;JKRisLegacy(Ljava/util/Map;)Z clusterPropsLjava/util/Map;getZkStateReader.()Lorg/apache/solr/common/cloud/ZkStateReader; access$000()Lorg/slf4j/Logger; access$100H(Lorg/apache/solr/cloud/Overseer;)Lorg/apache/solr/cloud/Overseer$Stats;x0 access$200#(Lorg/apache/solr/cloud/Overseer;)J access$202$(Lorg/apache/solr/cloud/Overseer;J)Jx1 access$400U(Lorg/apache/solr/cloud/Overseer;)Lorg/apache/solr/cloud/OverseerCollectionProcessor; access$500F(Lorg/apache/solr/cloud/Overseer;)Lorg/apache/solr/cloud/ZkController; SourceFile Overseer.java $org/apache/solr/common/SolrExceptionk mnnumShards is a required param op qrjava/lang/StringBuilder shard st su vwx yzshards is a required param,j {| }w ~ k$org/apache/solr/cloud/Overseer$Stats k  Overseer (id= ) starting   java/lang/ThreadGroupOverseer state updater. -org/apache/solr/cloud/Overseer$OverseerThread2org/apache/solr/cloud/Overseer$ClusterStateUpdater OverseerStateUpdate-  %Overseer collection creation process.1org/apache/solr/cloud/OverseerCollectionProcessor OverseerCollectionProcessor- 'Overseer Hdfs SolrCore Failover Thread.7org/apache/solr/cloud/OverseerAutoReplicaFailoverThread OverseerHdfsCoreFailoverThread-  ) closing   &org/apache/solr/cloud/DistributedQueue/overseer/queue /overseer/queue-work$org/apache/solr/cloud/DistributedMap /overseer/collection-map-running "/overseer/collection-map-completed /overseer/collection-map-failure /overseer/collection-queue-work /overseer  8org/apache/zookeeper/KeeperException$NodeExistsExceptionjava/lang/InterruptedExceptionCould not create Overseer node  java/lang/RuntimeException $org/apache/zookeeper/KeeperExceptionfalse legacyCloud  zorg/apache/solr/cloud/Overseer java/lang/Objectjava/io/Closeable'org/apache/solr/cloud/Overseer$FailedOp#org/apache/solr/cloud/Overseer$Stat+org/apache/solr/cloud/Overseer$LeaderStatus operation deletecoreremovecollection removeshardaddroutingruleremoveroutingrulestatequit createshardupdateshardstatejava/lang/String.org/apache/solr/common/SolrException$ErrorCode ErrorCode BAD_REQUEST0Lorg/apache/solr/common/SolrException$ErrorCode;E(Lorg/apache/solr/common/SolrException$ErrorCode;Ljava/lang/String;)Vjava/lang/IntegerintValue()Iappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;(I)Ljava/lang/StringBuilder;toString()Ljava/lang/String;java/util/Listadd(Ljava/lang/Object;)Zsplit'(Ljava/lang/String;)[Ljava/lang/String;trimisEmpty()Zorg/slf4j/Loggerinfo*org/apache/solr/common/cloud/ZkStateReader getZkClient-()Lorg/apache/solr/common/cloud/SolrZkClient;(Lorg/apache/solr/cloud/Overseer;Lorg/apache/solr/common/cloud/ZkStateReader;Ljava/lang/String;Lorg/apache/solr/cloud/Overseer$Stats;)V_(Lorg/apache/solr/cloud/Overseer;Ljava/lang/ThreadGroup;Ljava/io/Closeable;Ljava/lang/String;)V setDaemon(Z)V(Lorg/apache/solr/common/cloud/ZkStateReader;Ljava/lang/String;Lorg/apache/solr/handler/component/ShardHandler;Ljava/lang/String;Lorg/apache/solr/cloud/Overseer$Stats;)V{(Lorg/apache/solr/core/ConfigSolr;Lorg/apache/solr/common/cloud/ZkStateReader;Lorg/apache/solr/update/UpdateShardHandler;)Vorg/apache/solr/util/IOUtils closeQuietly(Ljava/io/Closeable;)V interruptv(Lorg/apache/solr/common/cloud/SolrZkClient;Ljava/lang/String;Ljava/util/List;Lorg/apache/solr/cloud/Overseer$Stats;)VP(Lorg/apache/solr/common/cloud/SolrZkClient;Ljava/lang/String;Ljava/util/List;)Vorg/apache/zookeeper/CreateMode PERSISTENT!Lorg/apache/zookeeper/CreateMode;)org/apache/solr/common/cloud/SolrZkClientcreateJ(Ljava/lang/String;[BLorg/apache/zookeeper/CreateMode;Z)Ljava/lang/String;error*(Ljava/lang/String;Ljava/lang/Throwable;)Vjava/lang/Thread currentThread()Ljava/lang/Thread;(Ljava/lang/Throwable;)V java/util/Mapget&(Ljava/lang/Object;)Ljava/lang/Object;equalsorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!\^_jklmnklopklqrklstkluvklwxklyzkl{|}l~klkl kk@*Y =* ' Y  `N+-Wױnopq1r9p?u*1k,}@@ @ +f+Y +M,>6.,2:*W*Y & xyz*{=|IzO~Xe>*k74}1}ffk f  6** **+*,*-**Y** X $/5H6666k666WP! .*+ *!*" Y #+$%*&'(Y)*M*+Y*,,Y**+*- Y .+/0*01(Y2*N*3Y*+***4*+Y*-* Y 5+/6*61(Y7*:8Y***9:*+Y* Y :+/;*;1*0<*6<*;<R .8Bs{&->..kBVA!/*0 !x5*! Y #* =%*"*!+/4 5O*0*0>*0?*6*6>*6?*;*;>*;?*0*6*;6 #*18?DIN O 6 *Y@  I*'AY*B+C I*'AY*D+C >*'EY*FG  >*'EY*HG  ! >*'EY*IG &' 6 *YJ,  I*'AY*K+C 01 F*LMNW7L3LQ+RSTUY+VLQ+RUY+VOP0W2 6@7@9:!;'<0=1><?EA*1FQCZ KX*YZ[C @/*G F/*F /*F ;*]F/*F /*F " \]TbB`\a c\d \e +\f,\gh\i@OW l@