ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mpapirkovs...@apache.org
Subject ambari git commit: AMBARI-9115. Add Metrics Sytem to 2.* stacks. (mpapirkovskyy)
Date Mon, 02 Feb 2015 15:46:18 GMT
Repository: ambari
Updated Branches:
  refs/heads/trunk 594daa406 -> 9b1a855b9


AMBARI-9115. Add Metrics Sytem to 2.* stacks. (mpapirkovskyy)


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/9b1a855b
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/9b1a855b
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/9b1a855b

Branch: refs/heads/trunk
Commit: 9b1a855b94259092dccdf36c4be05e7f86d7b464
Parents: 594daa4
Author: Myroslav Papirkovskyy <mpapyrkovskyy@hortonworks.com>
Authored: Mon Feb 2 17:39:41 2015 +0200
Committer: Myroslav Papirkovskyy <mpapyrkovskyy@hortonworks.com>
Committed: Mon Feb 2 17:46:14 2015 +0200

----------------------------------------------------------------------
 .../stacks/HDP/2.0.6/role_command_order.json    |   2 +
 .../stacks/HDP/2.0.6/services/AMS/metainfo.xml  |  26 ++++
 .../stacks/HDP/2.0.6/services/stack_advisor.py  | 122 ++++++++++++++++++-
 .../stacks/HDP/2.2/role_command_order.json      |   2 -
 .../stacks/HDP/2.2/services/AMS/metainfo.xml    |  26 ----
 .../stacks/HDP/2.2/services/stack_advisor.py    | 116 ------------------
 6 files changed, 148 insertions(+), 146 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/9b1a855b/ambari-server/src/main/resources/stacks/HDP/2.0.6/role_command_order.json
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.0.6/role_command_order.json b/ambari-server/src/main/resources/stacks/HDP/2.0.6/role_command_order.json
index d40d440..0607d9d 100644
--- a/ambari-server/src/main/resources/stacks/HDP/2.0.6/role_command_order.json
+++ b/ambari-server/src/main/resources/stacks/HDP/2.0.6/role_command_order.json
@@ -29,6 +29,8 @@
   },
   "_comment" : "Dependencies that are used when GLUSTERFS is not present in cluster",
   "optional_no_glusterfs": {
+    "METRIC_COLLECTOR-START": ["NAMENODE-START", "DATANODE-START"],
+    "AMS_SERVICE_CHECK-SERVICE_CHECK": ["METRIC_COLLECTOR-START", "HDFS_SERVICE_CHECK-SERVICE_CHECK"],
     "SECONDARY_NAMENODE-START": ["NAMENODE-START"],
     "RESOURCEMANAGER-START": ["NAMENODE-START", "DATANODE-START"],
     "NODEMANAGER-START": ["NAMENODE-START", "DATANODE-START", "RESOURCEMANAGER-START"],

http://git-wip-us.apache.org/repos/asf/ambari/blob/9b1a855b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/AMS/metainfo.xml
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/AMS/metainfo.xml b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/AMS/metainfo.xml
new file mode 100644
index 0000000..f0fa469
--- /dev/null
+++ b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/AMS/metainfo.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0"?>
+<!--
+   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.
+-->
+<metainfo>
+  <schemaVersion>2.0</schemaVersion>
+  <services>
+    <service>
+      <name>AMS</name>
+      <extends>common-services/AMS/0.1.0</extends>
+    </service>
+  </services>
+</metainfo>

http://git-wip-us.apache.org/repos/asf/ambari/blob/9b1a855b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/stack_advisor.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/stack_advisor.py b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/stack_advisor.py
index 1c1e690..2cdecba 100644
--- a/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/stack_advisor.py
+++ b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/stack_advisor.py
@@ -84,7 +84,8 @@ class HDP206StackAdvisor(DefaultStackAdvisor):
       "YARN": self.recommendYARNConfigurations,
       "MAPREDUCE2": self.recommendMapReduce2Configurations,
       "HDFS": self.recommendHDFSConfigurations,
-      "HBASE": self.recommendHbaseEnvConfigurations
+      "HBASE": self.recommendHbaseEnvConfigurations,
+      "AMS": self.recommendAmsConfigurations
     }
 
   def putProperty(self, config, configType):
@@ -125,6 +126,32 @@ class HDP206StackAdvisor(DefaultStackAdvisor):
     putHbaseProperty('hbase_regionserver_heapsize', int(clusterData['hbaseRam']) * 1024)
     putHbaseProperty('hbase_master_heapsize', int(clusterData['hbaseRam']) * 1024)
 
+  def recommendAmsConfigurations(self, configurations, clusterData, services, hosts):
+    putAmsHbaseSiteProperty = self.putProperty(configurations, "ams-hbase-site")
+    putTimelineServiceProperty = self.putProperty(configurations, "ams-site")
+    putHbaseEnvProperty = self.putProperty(configurations, "ams-hbase-env")
+
+    amsCollectorHosts = self.getComponentHostNames(services, "AMS", "METRIC_COLLECTOR")
+    putHbaseEnvProperty("hbase_regionserver_heapsize", "1024m")
+    putAmsHbaseSiteProperty("hfile.block.cache.size", 0.3)
+    putAmsHbaseSiteProperty("hbase.regionserver.global.memstore.upperLimit", 0.5)
+    putAmsHbaseSiteProperty("hbase.regionserver.global.memstore.lowerLimit", 0.4)
+    putTimelineServiceProperty("timeline.metrics.host.aggregator.ttl", 86400)
+
+    # TODO recommend configuration for multiple AMS collectors
+    if len(amsCollectorHosts) > 1:
+      pass
+    else:
+      totalHostsCount = len(hosts["items"])
+      if totalHostsCount > 400:
+        putHbaseEnvProperty("hbase_master_heapsize", "12288m")
+      elif totalHostsCount > 100:
+        putHbaseEnvProperty("hbase_master_heapsize", "6144m")
+      elif totalHostsCount > 50:
+        putHbaseEnvProperty("hbase_master_heapsize", "2048m")
+      else:
+        putHbaseEnvProperty("hbase_master_heapsize", "1024m")
+
   def getConfigurationClusterSummary(self, servicesList, hosts, components):
 
     hBaseInstalled = False
@@ -228,9 +255,100 @@ class HDP206StackAdvisor(DefaultStackAdvisor):
       "HDFS": {"hadoop-env": self.validateHDFSConfigurationsEnv},
       "MAPREDUCE2": {"mapred-site": self.validateMapReduce2Configurations},
       "YARN": {"yarn-site": self.validateYARNConfigurations},
-      "HBASE": {"hbase-env": self.validateHbaseEnvConfigurations}
+      "HBASE": {"hbase-env": self.validateHbaseEnvConfigurations},
+      "AMS": {"ams-hbase-site": self.validateAmsHbaseSiteConfigurations,
+              "ams-hbase-env": self.validateAmsHbaseEnvConfigurations,
+              "ams-site": self.validateAmsSiteConfigurations},
     }
 
+  def validateAmsSiteConfigurations(self, properties, recommendedDefaults, configurations,
services, hosts):
+    validationItems = []
+
+    op_mode = properties.get("timeline.metrics.service.operation.mode")
+    correct_op_mode_item = None
+    if op_mode not in ("embedded", "distributed"):
+      correct_op_mode_item = self.getErrorItem("Correct value should be set.")
+      pass
+
+    validationItems.extend([{"config-name":'timeline.metrics.service.operation.mode', "item":
correct_op_mode_item }])
+    return self.toConfigurationValidationProblems(validationItems, "ams-site")
+
+  def validateAmsHbaseSiteConfigurations(self, properties, recommendedDefaults, configurations,
services, hosts):
+
+    amsCollectorHosts = self.getComponentHostNames(services, "AMS", "METRIC_COLLECTOR")
+    ams_site = getSiteProperties(configurations, "ams-site")
+
+    recommendedDiskSpace = 10485760
+    # TODO validate configuration for multiple AMS collectors
+    if len(amsCollectorHosts) > 1:
+      pass
+    else:
+      totalHostsCount = len(hosts["items"])
+      if totalHostsCount > 400:
+        recommendedDiskSpace  = 104857600  # * 1k == 100 Gb
+      elif totalHostsCount > 100:
+        recommendedDiskSpace  = 52428800  # * 1k == 50 Gb
+      elif totalHostsCount > 50:
+        recommendedDiskSpace  = 20971520  # * 1k == 20 Gb
+
+
+    validationItems = []
+    for collectorHostName in amsCollectorHosts:
+      for host in hosts["items"]:
+        if host["Hosts"]["host_name"] == collectorHostName:
+          validationItems.extend([ {"config-name": 'hbase.rootdir', "item": self.validatorEnoughDiskSpace(properties,
'hbase.rootdir', host["Hosts"], recommendedDiskSpace)}])
+          break
+
+    rootdir_item = None
+    op_mode = ams_site.get("timeline.metrics.service.operation.mode")
+    hbase_rootdir = properties.get("hbase.rootdir")
+    if op_mode == "distributed" and not hbase_rootdir.startswith("hdfs://"):
+      rootdir_item = self.getWarnItem("In distributed mode hbase.rootdir should point to
HDFS. Collector will operate in embedded mode otherwise.")
+      pass
+
+    distributed_item = None
+    distributed = properties.get("hbase.cluster.distributed")
+    if hbase_rootdir.startswith("hdfs://") and not distributed.lower() == "true":
+      distributed_item = self.getErrorItem("Distributed property should be set to true if
hbase.rootdir points to HDFS.")
+
+    validationItems.extend([{"config-name":'hbase.rootdir', "item": rootdir_item },
+                            {"config-name":'hbase.cluster.distributed', "item": distributed_item
}])
+
+    return self.toConfigurationValidationProblems(validationItems, "ams-hbase-site")
+
+  def validateAmsHbaseEnvConfigurations(self, properties, recommendedDefaults, configurations,
services, hosts):
+    regionServerItem = self.validatorLessThenDefaultValue(properties, recommendedDefaults,
"hbase_regionserver_heapsize")
+    masterItem = self.validatorLessThenDefaultValue(properties, recommendedDefaults, "hbase_master_heapsize")
+    ams_env = getSiteProperties(configurations, "ams-env")
+    logDirItem = self.validatorEqualsPropertyItem(properties, "hbase_log_dir",
+                                                  ams_env, "ams_collector_log_dir")
+
+    if masterItem is None:
+      hbase_master_heapsize = formatXmxSizeToBytes(properties["hbase_master_heapsize"])
+
+      # TODO Add AMS Collector Xmx property to ams-env
+      # Collector 512m + HBASE Master heapsize
+      # For standalone HBase, master's heap memory is used by regionserver as well
+      requiredMemory = 536870912 + hbase_master_heapsize
+
+      amsCollectorHosts = self.getComponentHostNames(services, "AMS", "METRIC_COLLECTOR")
+      for collectorHostName in amsCollectorHosts:
+        for host in hosts["items"]:
+          if host["Hosts"]["host_name"] == collectorHostName:
+            if host["Hosts"]["total_mem"] * 1024 < requiredMemory:  # in bytes
+              message = "Not enough total RAM on the host {0}, " \
+                        "at least {1} MB required" \
+                .format(collectorHostName, requiredMemory/1048576)  # MB
+              regionServerItem = self.getWarnItem(message)
+              masterItem = self.getWarnItem(message)
+              break
+
+    validationItems = [{"config-name": "hbase_regionserver_heapsize", "item": regionServerItem},
+                       {"config-name": "hbase_master_heapsize", "item": masterItem},
+                       {"config-name": "hbase_log_dir", "item": logDirItem}]
+    return self.toConfigurationValidationProblems(validationItems, "ams-hbase-env")
+
+
   def validateServiceConfigurations(self, serviceName):
     return self.getServiceConfigurationValidators().get(serviceName, None)
 

http://git-wip-us.apache.org/repos/asf/ambari/blob/9b1a855b/ambari-server/src/main/resources/stacks/HDP/2.2/role_command_order.json
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.2/role_command_order.json b/ambari-server/src/main/resources/stacks/HDP/2.2/role_command_order.json
index b8840d8..79eaf78 100644
--- a/ambari-server/src/main/resources/stacks/HDP/2.2/role_command_order.json
+++ b/ambari-server/src/main/resources/stacks/HDP/2.2/role_command_order.json
@@ -6,8 +6,6 @@
     "RANGER_SERVICE_CHECK-SERVICE_CHECK" : ["RANGER_ADMIN-START"],
     "RANGER_SERVICE_CHECK-SERVICE_CHECK" : ["RANGER_USERSYNC-START"],
     "FALCON_SERVER-START": ["NAMENODE-START", "DATANODE-START", "OOZIE_SERVER-START"],
-    "METRIC_COLLECTOR-START": ["NAMENODE-START", "DATANODE-START"],
-    "AMS_SERVICE_CHECK-SERVICE_CHECK": ["METRIC_COLLECTOR-START", "HDFS_SERVICE_CHECK-SERVICE_CHECK"],
     "WEBHCAT_SERVICE_CHECK-SERVICE_CHECK": ["WEBHCAT_SERVER-START"],
     "FLUME_SERVICE_CHECK-SERVICE_CHECK": ["FLUME_HANDLER-START"],
     "FALCON_SERVICE_CHECK-SERVICE_CHECK": ["FALCON_SERVER-START"],

http://git-wip-us.apache.org/repos/asf/ambari/blob/9b1a855b/ambari-server/src/main/resources/stacks/HDP/2.2/services/AMS/metainfo.xml
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.2/services/AMS/metainfo.xml b/ambari-server/src/main/resources/stacks/HDP/2.2/services/AMS/metainfo.xml
deleted file mode 100644
index f0fa469..0000000
--- a/ambari-server/src/main/resources/stacks/HDP/2.2/services/AMS/metainfo.xml
+++ /dev/null
@@ -1,26 +0,0 @@
-<?xml version="1.0"?>
-<!--
-   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.
--->
-<metainfo>
-  <schemaVersion>2.0</schemaVersion>
-  <services>
-    <service>
-      <name>AMS</name>
-      <extends>common-services/AMS/0.1.0</extends>
-    </service>
-  </services>
-</metainfo>

http://git-wip-us.apache.org/repos/asf/ambari/blob/9b1a855b/ambari-server/src/main/resources/stacks/HDP/2.2/services/stack_advisor.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.2/services/stack_advisor.py b/ambari-server/src/main/resources/stacks/HDP/2.2/services/stack_advisor.py
index 7c7adac..6a5aab5 100644
--- a/ambari-server/src/main/resources/stacks/HDP/2.2/services/stack_advisor.py
+++ b/ambari-server/src/main/resources/stacks/HDP/2.2/services/stack_advisor.py
@@ -91,32 +91,6 @@ class HDP22StackAdvisor(HDP21StackAdvisor):
     putTezProperty("tez.runtime.io.sort.mb", min(int(taskResourceMemory * 0.4), 2047))
     putTezProperty("tez.runtime.unordered.output.buffer.size-mb", int(taskResourceMemory
* 0.075))
 
-  def recommendAmsConfigurations(self, configurations, clusterData, services, hosts):
-    putAmsHbaseSiteProperty = self.putProperty(configurations, "ams-hbase-site")
-    putTimelineServiceProperty = self.putProperty(configurations, "ams-site")
-    putHbaseEnvProperty = self.putProperty(configurations, "ams-hbase-env")
-
-    amsCollectorHosts = self.getComponentHostNames(services, "AMS", "METRIC_COLLECTOR")
-    putHbaseEnvProperty("hbase_regionserver_heapsize", "1024m")
-    putAmsHbaseSiteProperty("hfile.block.cache.size", 0.3)
-    putAmsHbaseSiteProperty("hbase.regionserver.global.memstore.upperLimit", 0.5)
-    putAmsHbaseSiteProperty("hbase.regionserver.global.memstore.lowerLimit", 0.4)
-    putTimelineServiceProperty("timeline.metrics.host.aggregator.ttl", 86400)
-
-  # TODO recommend configuration for multiple AMS collectors
-    if len(amsCollectorHosts) > 1:
-      pass
-    else:
-      totalHostsCount = len(hosts["items"])
-      if totalHostsCount > 400:
-        putHbaseEnvProperty("hbase_master_heapsize", "12288m")
-      elif totalHostsCount > 100:
-        putHbaseEnvProperty("hbase_master_heapsize", "6144m")
-      elif totalHostsCount > 50:
-        putHbaseEnvProperty("hbase_master_heapsize", "2048m")
-      else:
-        putHbaseEnvProperty("hbase_master_heapsize", "1024m")
-
   def getServiceConfigurationValidators(self):
     parentValidators = super(HDP22StackAdvisor, self).getServiceConfigurationValidators()
     childValidators = {
@@ -125,9 +99,6 @@ class HDP22StackAdvisor(HDP21StackAdvisor):
       "HIVE": {"hiveserver2-site": self.validateHIVEConfigurations},
       "HBASE": {"hbase-site": self.validateHBASEConfigurations},
       "MAPREDUCE2": {"mapred-site": self.validateMapReduce2Configurations},
-      "AMS": {"ams-hbase-site": self.validateAmsHbaseSiteConfigurations,
-              "ams-hbase-env": self.validateAmsHbaseEnvConfigurations,
-              "ams-site": self.validateAmsSiteConfigurations},
       "TEZ": {"tez-site": self.validateTezConfigurations}
     }
     parentValidators.update(childValidators)
@@ -140,93 +111,6 @@ class HDP22StackAdvisor(HDP21StackAdvisor):
                         {"config-name": 'tez.runtime.unordered.output.buffer.size-mb', "item":
self.validatorLessThenDefaultValue(properties, recommendedDefaults, 'tez.runtime.unordered.output.buffer.size-mb')},]
     return self.toConfigurationValidationProblems(validationItems, "tez-site")
 
-  def validateAmsSiteConfigurations(self, properties, recommendedDefaults, configurations,
services, hosts):
-    validationItems = []
-
-    op_mode = properties.get("timeline.metrics.service.operation.mode")
-    correct_op_mode_item = None
-    if op_mode not in ("embedded", "distributed"):
-      correct_op_mode_item = self.getErrorItem("Correct value should be set.")
-      pass
-
-    validationItems.extend([{"config-name":'timeline.metrics.service.operation.mode', "item":
correct_op_mode_item }])
-    return self.toConfigurationValidationProblems(validationItems, "ams-site")
-
-  def validateAmsHbaseSiteConfigurations(self, properties, recommendedDefaults, configurations,
services, hosts):
-
-    amsCollectorHosts = self.getComponentHostNames(services, "AMS", "METRIC_COLLECTOR")
-    ams_site = getSiteProperties(configurations, "ams-site")
-
-    recommendedDiskSpace = 10485760
-    # TODO validate configuration for multiple AMS collectors
-    if len(amsCollectorHosts) > 1:
-      pass
-    else:
-      totalHostsCount = len(hosts["items"])
-      if totalHostsCount > 400:
-        recommendedDiskSpace  = 104857600  # * 1k == 100 Gb
-      elif totalHostsCount > 100:
-        recommendedDiskSpace  = 52428800  # * 1k == 50 Gb
-      elif totalHostsCount > 50:
-        recommendedDiskSpace  = 20971520  # * 1k == 20 Gb
-
-
-    validationItems = []
-    for collectorHostName in amsCollectorHosts:
-      for host in hosts["items"]:
-        if host["Hosts"]["host_name"] == collectorHostName:
-          validationItems.extend([ {"config-name": 'hbase.rootdir', "item": self.validatorEnoughDiskSpace(properties,
'hbase.rootdir', host["Hosts"], recommendedDiskSpace)}])
-          break
-
-    rootdir_item = None
-    op_mode = ams_site.get("timeline.metrics.service.operation.mode")
-    hbase_rootdir = properties.get("hbase.rootdir")
-    if op_mode == "distributed" and not hbase_rootdir.startswith("hdfs://"):
-      rootdir_item = self.getWarnItem("In distributed mode hbase.rootdir should point to
HDFS. Collector will operate in embedded mode otherwise.")
-      pass
-
-    distributed_item = None
-    distributed = properties.get("hbase.cluster.distributed")
-    if hbase_rootdir.startswith("hdfs://") and not distributed.lower() == "true":
-      distributed_item = self.getErrorItem("Distributed property should be set to true if
hbase.rootdir points to HDFS.")
-
-    validationItems.extend([{"config-name":'hbase.rootdir', "item": rootdir_item },
-                            {"config-name":'hbase.cluster.distributed', "item": distributed_item
}])
-
-    return self.toConfigurationValidationProblems(validationItems, "ams-hbase-site")
-
-  def validateAmsHbaseEnvConfigurations(self, properties, recommendedDefaults, configurations,
services, hosts):
-    regionServerItem = self.validatorLessThenDefaultValue(properties, recommendedDefaults,
"hbase_regionserver_heapsize")
-    masterItem = self.validatorLessThenDefaultValue(properties, recommendedDefaults, "hbase_master_heapsize")
-    ams_env = getSiteProperties(configurations, "ams-env")
-    logDirItem = self.validatorEqualsPropertyItem(properties, "hbase_log_dir",
-                                                  ams_env, "ams_collector_log_dir")
-
-    if masterItem is None:
-      hbase_master_heapsize = formatXmxSizeToBytes(properties["hbase_master_heapsize"])
-
-      # TODO Add AMS Collector Xmx property to ams-env
-      # Collector 512m + HBASE Master heapsize
-      # For standalone HBase, master's heap memory is used by regionserver as well
-      requiredMemory = 536870912 + hbase_master_heapsize
-
-      amsCollectorHosts = self.getComponentHostNames(services, "AMS", "METRIC_COLLECTOR")
-      for collectorHostName in amsCollectorHosts:
-        for host in hosts["items"]:
-          if host["Hosts"]["host_name"] == collectorHostName:
-            if host["Hosts"]["total_mem"] * 1024 < requiredMemory:  # in bytes
-              message = "Not enough total RAM on the host {0}, " \
-                        "at least {1} MB required" \
-                        .format(collectorHostName, requiredMemory/1048576)  # MB
-              regionServerItem = self.getWarnItem(message)
-              masterItem = self.getWarnItem(message)
-              break
-
-    validationItems = [{"config-name": "hbase_regionserver_heapsize", "item": regionServerItem},
-                       {"config-name": "hbase_master_heapsize", "item": masterItem},
-                       {"config-name": "hbase_log_dir", "item": logDirItem}]
-    return self.toConfigurationValidationProblems(validationItems, "ams-hbase-env")
-
   def recommendMapReduce2Configurations(self, configurations, clusterData, services, hosts):
     putMapredProperty = self.putProperty(configurations, "mapred-site")
     putMapredProperty('yarn.app.mapreduce.am.resource.mb', int(clusterData['amMemory']))


Mime
View raw message