107107public class ZookeeperFederationStateStore implements FederationStateStore {
108108
109109 private static final Logger LOG =
110- LoggerFactory .getLogger (ZookeeperFederationStateStore .class );
110+ LoggerFactory .getLogger (ZookeeperFederationStateStore .class );
111111
112112 private final static String ROOT_ZNODE_NAME_MEMBERSHIP = "memberships" ;
113113 private final static String ROOT_ZNODE_NAME_APPLICATION = "applications" ;
114114 private final static String ROOT_ZNODE_NAME_POLICY = "policies" ;
115115
116- /**
117- * Interface to Zookeeper.
118- */
116+ /** Interface to Zookeeper. */
119117 private ZKCuratorManager zkManager ;
120118
121- /**
122- * Directory to store the state store data.
123- */
119+ /** Directory to store the state store data.*/
124120 private String baseZNode ;
125121
126122 private String appsZNode ;
@@ -131,15 +127,15 @@ public class ZookeeperFederationStateStore implements FederationStateStore {
131127
132128 @ VisibleForTesting
133129 private ZKFederationStateStoreOpDurations opDurations =
134- ZKFederationStateStoreOpDurations .getInstance ();
130+ ZKFederationStateStoreOpDurations .getInstance ();
135131
136132 @ Override
137133 public void init (Configuration conf ) throws YarnException {
138134 LOG .info ("Initializing ZooKeeper connection" );
139135
140136 baseZNode = conf .get (
141- YarnConfiguration .FEDERATION_STATESTORE_ZK_PARENT_PATH ,
142- YarnConfiguration .DEFAULT_FEDERATION_STATESTORE_ZK_PARENT_PATH );
137+ YarnConfiguration .FEDERATION_STATESTORE_ZK_PARENT_PATH ,
138+ YarnConfiguration .DEFAULT_FEDERATION_STATESTORE_ZK_PARENT_PATH );
143139 try {
144140 this .zkManager = new ZKCuratorManager (conf );
145141 this .zkManager .start ();
@@ -217,7 +213,7 @@ public AddApplicationHomeSubClusterResponse addApplicationHomeSubCluster(
217213 FederationStateStoreUtils .logAndThrowStoreException (LOG , errMsg );
218214 }
219215 SubClusterId newSubClusterId =
220- request .getApplicationHomeSubCluster ().getHomeSubCluster ();
216+ request .getApplicationHomeSubCluster ().getHomeSubCluster ();
221217 putApp (appId , newSubClusterId , true );
222218
223219 opDurations .addUpdateAppHomeSubClusterDuration (clock .getTime () - start );
0 commit comments