YARN-11250. Fix CodeStyle.

Author: slfan1989

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/store/impl/ZKFederationStateStoreOpDurations.java

@@ -101,55 +101,55 @@ public synchronized void getMetrics(MetricsCollector collector, boolean all) {
     registry.snapshot(collector.addRecord(registry.info()), all);
   }
 
-  public void addAppHomeSubClusterDuration(long endTime, long startTime) {
+  public void addAppHomeSubClusterDuration(long startTime, long endTime) {
     addAppHomeSubCluster.add(endTime - startTime);
   }
 
-  public void addUpdateAppHomeSubClusterDuration(long endTime, long startTime) {
+  public void addUpdateAppHomeSubClusterDuration(long startTime, long endTime) {
     updateAppHomeSubCluster.add(endTime - startTime);
   }
 
-  public void addGetAppHomeSubClusterDuration(long endTime, long startTime) {
+  public void addGetAppHomeSubClusterDuration(long startTime, long endTime) {
     getAppHomeSubCluster.add(endTime - startTime);
   }
 
-  public void addGetAppsHomeSubClusterDuration(long endTime, long startTime) {
+  public void addGetAppsHomeSubClusterDuration(long startTime, long endTime) {
     getAppsHomeSubCluster.add(endTime - startTime);
   }
 
-  public void addDeleteAppHomeSubClusterDuration(long endTime, long startTime) {
+  public void addDeleteAppHomeSubClusterDuration(long startTime, long endTime) {
     deleteAppHomeSubCluster.add(endTime - startTime);
   }
 
-  public void addRegisterSubClusterDuration(long endTime, long startTime) {
+  public void addRegisterSubClusterDuration(long startTime, long endTime) {
     registerSubCluster.add(endTime - startTime);
   }
 
-  public void addDeregisterSubClusterDuration(long endTime, long startTime) {
+  public void addDeregisterSubClusterDuration(long startTime, long endTime) {
     deregisterSubCluster.add(endTime - startTime);
   }
 
-  public void addSubClusterHeartbeatDuration(long endTime, long startTime) {
+  public void addSubClusterHeartbeatDuration(long startTime, long endTime) {
     subClusterHeartbeat.add(endTime - startTime);
   }
 
-  public void addGetSubClusterDuration(long endTime, long startTime) {
+  public void addGetSubClusterDuration(long startTime, long endTime) {
     getSubCluster.add(endTime - startTime);
   }
 
-  public void addGetSubClustersDuration(long endTime, long startTime) {
+  public void addGetSubClustersDuration(long startTime, long endTime) {
     getSubClusters.add(endTime - startTime);
   }
 
-  public void addGetPolicyConfigurationDuration(long endTime, long startTime) {
+  public void addGetPolicyConfigurationDuration(long startTime, long endTime) {
     getPolicyConfiguration.add(endTime - startTime);
   }
 
-  public void addSetPolicyConfigurationDuration(long endTime, long startTime) {
+  public void addSetPolicyConfigurationDuration(long startTime, long endTime) {
     setPolicyConfiguration.add(endTime - startTime);
   }
 
-  public void addGetPoliciesConfigurationsDuration(long endTime, long startTime) {
+  public void addGetPoliciesConfigurationsDuration(long startTime, long endTime) {
     getPoliciesConfigurations.add(endTime - startTime);
   }
 }

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/store/impl/ZookeeperFederationStateStore.java

@@ -193,7 +193,7 @@ public AddApplicationHomeSubClusterResponse addApplicationHomeSubCluster(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addAppHomeSubClusterDuration(end, start);
+    opDurations.addAppHomeSubClusterDuration(start, end);
     return AddApplicationHomeSubClusterResponse
         .newInstance(homeSubCluster);
   }
@@ -218,7 +218,7 @@ public AddApplicationHomeSubClusterResponse addApplicationHomeSubCluster(
     putApp(appId, newSubClusterId, true);
 
     long end = clock.getTime();
-    opDurations.addUpdateAppHomeSubClusterDuration(end, start);
+    opDurations.addUpdateAppHomeSubClusterDuration(start, end);
     return UpdateApplicationHomeSubClusterResponse.newInstance();
   }
 
@@ -235,7 +235,7 @@ public GetApplicationHomeSubClusterResponse getApplicationHomeSubCluster(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addGetAppHomeSubClusterDuration(end, start);
+    opDurations.addGetAppHomeSubClusterDuration(start, end);
     return GetApplicationHomeSubClusterResponse.newInstance(appId, homeSubCluster);
   }
 
@@ -258,7 +258,7 @@ public GetApplicationsHomeSubClusterResponse getApplicationsHomeSubCluster(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addGetAppsHomeSubClusterDuration(end, start);
+    opDurations.addGetAppsHomeSubClusterDuration(start, end);
     return GetApplicationsHomeSubClusterResponse.newInstance(result);
   }
 
@@ -291,7 +291,7 @@ public GetApplicationsHomeSubClusterResponse getApplicationsHomeSubCluster(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addDeleteAppHomeSubClusterDuration(end, start);
+    opDurations.addDeleteAppHomeSubClusterDuration(start, end);
     return DeleteApplicationHomeSubClusterResponse.newInstance();
   }
 
@@ -314,7 +314,7 @@ public SubClusterRegisterResponse registerSubCluster(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addRegisterSubClusterDuration(end, start);
+    opDurations.addRegisterSubClusterDuration(start, end);
     return SubClusterRegisterResponse.newInstance();
   }
 
@@ -336,7 +336,7 @@ public SubClusterDeregisterResponse deregisterSubCluster(
       putSubclusterInfo(subClusterId, subClusterInfo, true);
     }
     long end = clock.getTime();
-    opDurations.addDeregisterSubClusterDuration(end, start);
+    opDurations.addDeregisterSubClusterDuration(start, end);
     return SubClusterDeregisterResponse.newInstance();
   }
 
@@ -361,7 +361,7 @@ public SubClusterHeartbeatResponse subClusterHeartbeat(
 
     putSubclusterInfo(subClusterId, subClusterInfo, true);
     long end = clock.getTime();
-    opDurations.addSubClusterHeartbeatDuration(clock.getTime(), start);
+    opDurations.addSubClusterHeartbeatDuration(start, end);
     return SubClusterHeartbeatResponse.newInstance();
   }
 
@@ -383,7 +383,7 @@ public GetSubClusterInfoResponse getSubCluster(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addGetSubClusterDuration(end, start);
+    opDurations.addGetSubClusterDuration(start, end);
     return GetSubClusterInfoResponse.newInstance(subClusterInfo);
   }
 
@@ -407,7 +407,7 @@ public GetSubClustersInfoResponse getSubClusters(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addGetSubClustersDuration(end, start);
+    opDurations.addGetSubClustersDuration(start, end);
     return GetSubClustersInfoResponse.newInstance(result);
   }
 
@@ -431,7 +431,7 @@ public GetSubClusterPolicyConfigurationResponse getPolicyConfiguration(
       return null;
     }
     long end = clock.getTime();
-    opDurations.addGetPolicyConfigurationDuration(end, start);
+    opDurations.addGetPolicyConfigurationDuration(start, end);
     return GetSubClusterPolicyConfigurationResponse
         .newInstance(policy);
   }
@@ -451,7 +451,7 @@ public SetSubClusterPolicyConfigurationResponse setPolicyConfiguration(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addSetPolicyConfigurationDuration(end, start);
+    opDurations.addSetPolicyConfigurationDuration(start, end);
     return SetSubClusterPolicyConfigurationResponse.newInstance();
   }
 
@@ -475,7 +475,7 @@ public GetSubClusterPoliciesConfigurationsResponse getPoliciesConfigurations(
       FederationStateStoreUtils.logAndThrowStoreException(LOG, errMsg);
     }
     long end = clock.getTime();
-    opDurations.addGetPoliciesConfigurationsDuration(end, start);
+    opDurations.addGetPoliciesConfigurationsDuration(start, end);
     return GetSubClusterPoliciesConfigurationsResponse.newInstance(result);
   }