From 72d69856d5737dcd5a09fcbe744b0a15882e65bb Mon Sep 17 00:00:00 2001 From: Karthik Kambatla Date: Wed, 8 Jan 2014 03:31:36 +0000 Subject: [PATCH] YARN-1568. Rename clusterid to clusterId in ActiveRMInfoProto (kasha) git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1556436 13f79535-47bb-0310-9956-ffa450edef68 --- hadoop-yarn-project/CHANGES.txt | 2 ++ .../server/yarn_server_resourcemanager_service_protos.proto | 2 +- .../yarn/server/resourcemanager/EmbeddedElectorService.java | 6 +++--- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index 42270d8194f..12fe6774ebc 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -185,6 +185,8 @@ Release 2.4.0 - UNRELEASED YARN-1482. Modified WebApplicationProxy to make it work across ResourceManager fail-over. (Xuan Gong via vinodkv) + YARN-1568. Rename clusterid to clusterId in ActiveRMInfoProto (kasha) + OPTIMIZATIONS BUG FIXES diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/server/yarn_server_resourcemanager_service_protos.proto b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/server/yarn_server_resourcemanager_service_protos.proto index 91c80db0c81..e27f12a836a 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/server/yarn_server_resourcemanager_service_protos.proto +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/server/yarn_server_resourcemanager_service_protos.proto @@ -138,6 +138,6 @@ message RMStateVersionProto { ///////////// RM Failover related records //////////////////////// ////////////////////////////////////////////////////////////////// message ActiveRMInfoProto { - required string clusterid = 1; + required string clusterId = 1; required string rmId = 2; } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/EmbeddedElectorService.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/EmbeddedElectorService.java index 7b164418d34..0c09c2753c5 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/EmbeddedElectorService.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/EmbeddedElectorService.java @@ -172,7 +172,7 @@ public class EmbeddedElectorService extends AbstractService throws IOException { return YarnServerResourceManagerServiceProtos.ActiveRMInfoProto .newBuilder() - .setClusterid(clusterId) + .setClusterId(clusterId) .setRmId(rmId) .build() .toByteArray(); @@ -198,10 +198,10 @@ public class EmbeddedElectorService extends AbstractService } // Check if the passed proto corresponds to an RM in the same cluster - if (!proto.getClusterid().equals(clusterId)) { + if (!proto.getClusterId().equals(clusterId)) { LOG.error("Mismatched cluster! The other RM seems " + "to be from a different cluster. Current cluster = " + clusterId + - "Other RM's cluster = " + proto.getClusterid()); + "Other RM's cluster = " + proto.getClusterId()); return false; } return true;