YARN-11536. Fix CheckStyle.

Author: slfan1989

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/BatchSaveFederationQueuePoliciesRequest.java

@@ -0,0 +1,54 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.yarn.server.api.protocolrecords;
+
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Public;
+import org.apache.hadoop.classification.InterfaceStability.Unstable;
+import org.apache.hadoop.yarn.util.Records;
+
+import java.util.List;
+
+/**
+ * In Federation mode,
+ * we will support batch save queues policies to FederationStateStore.
+ */
+@Private
+@Unstable
+public abstract class BatchSaveFederationQueuePoliciesRequest {
+
+  @Private
+  @Unstable
+  public static BatchSaveFederationQueuePoliciesRequest newInstance(
+      List<FederationQueueWeight> federationQueueWeights) {
+    BatchSaveFederationQueuePoliciesRequest request =
+        Records.newRecord(BatchSaveFederationQueuePoliciesRequest.class);
+    request.setFederationQueueWeights(federationQueueWeights);
+    return request;
+  }
+
+  @Public
+  @Unstable
+  public abstract List<FederationQueueWeight> getFederationQueueWeights();
+
+  @Private
+  @Unstable
+  public abstract void setFederationQueueWeights(
+      List<FederationQueueWeight> federationQueueWeights);
+}

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/server/yarn_server_resourcemanager_service_protos.proto

@@ -180,6 +180,14 @@ message SaveFederationQueuePolicyResponseProto {
   required string message = 1;
 }
 
+message BatchSaveFederationQueuePoliciesRequestProto {
+  repeated FederationQueueWeightProto federationQueueWeights = 1;
+}
+
+message BatchSaveFederationQueuePoliciesResponseProto {
+  required string message = 1;
+}
+
 //////////////////////////////////////////////////////////////////
 ///////////// RM Failover related records ////////////////////////
 //////////////////////////////////////////////////////////////////

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/RouterCLI.java

@@ -381,6 +381,12 @@ private int handleSavePolicy(String policy) {
     }
   }
 
+  private int handBatchSavePolicies(String format, String policyFile) {
+    LOG.info("Batch Save Federation Policies. Format = {}, PolicyFile = {}.",
+        format, policyFile);
+    return 1;
+  }
+
   /**
    * We will parse the policy, and it has specific formatting requirements.
    *

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/FederationQueueWeightPBImpl.java

@@ -116,22 +116,42 @@ public void setHeadRoomAlpha(String headRoomAlpha) {
 
   @Override
   public String getQueue() {
+    FederationQueueWeightProtoOrBuilder p = this.viaProto ? this.proto : this.builder;
+    boolean hasQueue = p.hasQueue();
+    if (hasQueue) {
+      return p.getQueue();
+    }
     return null;
   }
 
   @Override
   public void setQueue(String queue) {
-
+    maybeInitBuilder();
+    if (queue == null) {
+      builder.clearQueue();
+      return;
+    }
+    builder.setQueue(queue);
   }
 
   @Override
   public String getPolicyManagerClassName() {
+    FederationQueueWeightProtoOrBuilder p = this.viaProto ? this.proto : this.builder;
+    boolean hasPolicyManagerClassName = p.hasPolicyManagerClassName();
+    if (hasPolicyManagerClassName) {
+      return p.getPolicyManagerClassName();
+    }
     return null;
   }
 
   @Override
   public void setPolicyManagerClassName(String policyManagerClassName) {
-
+    maybeInitBuilder();
+    if (policyManagerClassName == null) {
+      builder.clearPolicyManagerClassName();
+      return;
+    }
+    builder.setPolicyManagerClassName(policyManagerClassName);
   }
 
   @Override

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-ui/src/main/webapp/package.json

@@ -27,14 +27,14 @@
     "broccoli-merge-trees": "1.1.1",
     "ember-array-contains-helper": "1.0.2",
     "ember-bootstrap": "0.5.1",
-    "ember-cli": "1.13.14",
+    "ember-cli": "3.0.0",
     "ember-cli-app-version": "1.0.0",
-    "ember-cli-babel": "5.1.6",
+    "ember-cli-babel": "6.6.0",
     "ember-cli-content-security-policy": "0.4.0",
     "ember-cli-dependency-checker": "1.2.0",
     "ember-cli-htmlbars": "1.0.2",
     "ember-cli-htmlbars-inline-precompile": "0.3.1",
-    "ember-cli-ic-ajax": "0.2.1",
+    "ember-cli-ic-ajax": "1.0.0",
     "ember-cli-inject-live-reload": "1.4.0",
     "ember-cli-jquery-ui": "0.0.20",
     "ember-cli-moment-shim": "0.7.3",