Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 0603D200C47 for ; Thu, 30 Mar 2017 14:49:12 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 045DB160B9E; Thu, 30 Mar 2017 12:49:12 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id C9930160B8B for ; Thu, 30 Mar 2017 14:49:10 +0200 (CEST) Received: (qmail 12372 invoked by uid 500); 30 Mar 2017 12:49:10 -0000 Mailing-List: contact commits-help@ambari.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: ambari-dev@ambari.apache.org Delivered-To: mailing list commits@ambari.apache.org Received: (qmail 12247 invoked by uid 99); 30 Mar 2017 12:49:08 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 30 Mar 2017 12:49:08 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 53839E024D; Thu, 30 Mar 2017 12:49:08 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: dmitriusan@apache.org To: commits@ambari.apache.org Date: Thu, 30 Mar 2017 12:49:11 -0000 Message-Id: <2bd05641b4cb427f8071390ff3799a2b@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [4/4] ambari git commit: AMBARI-20617. Display log level, method name from stack_advisor in ambari-server.log (dlysnichenko) archived-at: Thu, 30 Mar 2017 12:49:12 -0000 AMBARI-20617. Display log level, method name from stack_advisor in ambari-server.log (dlysnichenko) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/9feb5d0f Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/9feb5d0f Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/9feb5d0f Branch: refs/heads/trunk Commit: 9feb5d0f9a4d2d287d6724896668fc297aa0a778 Parents: fb8d463 Author: Lisnichenko Dmitro Authored: Thu Mar 30 15:48:24 2017 +0300 Committer: Lisnichenko Dmitro Committed: Thu Mar 30 15:48:24 2017 +0300 ---------------------------------------------------------------------- .../HDFS/3.0.0.3.0/service_advisor.py | 27 +- .../HIVE/2.1.0.3.0/service_advisor.py | 25 +- .../SLIDER/0.91.0.3.0/service_advisor.py | 7 +- .../SPARK/2.2.0/service_advisor.py | 7 +- .../TEZ/0.9.0.3.0/service_advisor.py | 9 +- .../YARN/3.0.0.3.0/service_advisor.py | 259 ++++++++--------- .../ZOOKEEPER/3.4.9/service_advisor.py | 13 +- .../stacks/BIGTOP/0.8/services/stack_advisor.py | 3 +- .../stacks/HDP/2.0.6/services/stack_advisor.py | 7 +- .../stacks/HDP/2.1/services/stack_advisor.py | 3 +- .../stacks/HDP/2.2/services/stack_advisor.py | 3 +- .../stacks/HDP/2.3/services/stack_advisor.py | 3 +- .../stacks/HDP/2.5/services/stack_advisor.py | 277 +++++++++---------- .../stacks/HDP/2.6/services/stack_advisor.py | 27 +- .../stacks/HDPWIN/2.1/services/stack_advisor.py | 9 +- .../stacks/HDPWIN/2.2/services/stack_advisor.py | 3 +- .../stacks/PERF/1.0/services/stack_advisor.py | 3 +- .../src/main/resources/stacks/stack_advisor.py | 88 +++--- .../stacks/ODPi/2.0/services/stack_advisor.py | 21 +- 19 files changed, 404 insertions(+), 390 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/9feb5d0f/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/service_advisor.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/service_advisor.py b/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/service_advisor.py index a37ebc67..356ad59 100644 --- a/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/service_advisor.py +++ b/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/service_advisor.py @@ -24,7 +24,6 @@ import traceback import inspect # Local imports -from resource_management.core.logger import Logger from resource_management.libraries.functions.mounted_dirs_helper import get_mounts_with_multiple_data_dirs @@ -46,6 +45,8 @@ class HDFSServiceAdvisor(service_advisor.ServiceAdvisor): self.as_super = super(HDFSServiceAdvisor, self) self.as_super.__init__(*args, **kwargs) + self.initialize_logger("HDFSServiceAdvisor") + # Always call these methods self.modifyMastersWithMultipleInstances() self.modifyCardinalitiesDict() @@ -120,7 +121,7 @@ class HDFSServiceAdvisor(service_advisor.ServiceAdvisor): Get a list of errors. Must be overriden in child class. """ - Logger.info("Class: %s, Method: %s. Validating Service Component Layout." % + self.logger.info("Class: %s, Method: %s. Validating Service Component Layout." % (self.__class__.__name__, inspect.stack()[0][3])) # HDFS allows NameNode and Secondary NameNode to be on the same host. @@ -131,7 +132,7 @@ class HDFSServiceAdvisor(service_advisor.ServiceAdvisor): Entry point. Must be overriden in child class. """ - Logger.info("Class: %s, Method: %s. Recommending Service Configurations." % + self.logger.info("Class: %s, Method: %s. Recommending Service Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) # Due to the existing stack inheritance, make it clear where each calculation came from. @@ -146,7 +147,7 @@ class HDFSServiceAdvisor(service_advisor.ServiceAdvisor): Validate configurations for the service. Return a list of errors. The code for this function should be the same for each Service Advisor. """ - Logger.info("Class: %s, Method: %s. Validating Configurations." % + self.logger.info("Class: %s, Method: %s. Validating Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) validator = HDFSValidator() @@ -167,7 +168,7 @@ class HDFSRecommender(service_advisor.ServiceAdvisor): """ Recommend configurations for this service based on HDP 2.0.6. """ - Logger.info("Class: %s, Method: %s. Recommending Service Configurations." % + self.logger.info("Class: %s, Method: %s. Recommending Service Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) putHDFSProperty = self.putProperty(configurations, "hadoop-env", services) @@ -175,7 +176,7 @@ class HDFSRecommender(service_advisor.ServiceAdvisor): putHDFSSitePropertyAttributes = self.putPropertyAttribute(configurations, "hdfs-site") totalAvailableRam = clusterData['totalAvailableRam'] - Logger.info("Class: %s, Method: %s. Total Available Ram: %s" % (self.__class__.__name__, inspect.stack()[0][3], str(totalAvailableRam))) + self.logger.info("Class: %s, Method: %s. Total Available Ram: %s" % (self.__class__.__name__, inspect.stack()[0][3], str(totalAvailableRam))) putHDFSProperty('namenode_heapsize', max(int(totalAvailableRam / 2), 1024)) putHDFSProperty = self.putProperty(configurations, "hadoop-env", services) putHDFSProperty('namenode_opt_newsize', max(int(totalAvailableRam / 8), 128)) @@ -194,7 +195,7 @@ class HDFSRecommender(service_advisor.ServiceAdvisor): if len(namenodes.split(',')) > 1: putHDFSSitePropertyAttributes("dfs.namenode.rpc-address", "delete", "true") - Logger.info("Class: %s, Method: %s. HDFS nameservices: %s" % + self.logger.info("Class: %s, Method: %s. HDFS nameservices: %s" % (self.__class__.__name__, inspect.stack()[0][3], str(nameServices))) hdfs_mount_properties = [ @@ -203,7 +204,7 @@ class HDFSRecommender(service_advisor.ServiceAdvisor): ("dfs.namenode.checkpoint.dir", "SECONDARY_NAMENODE", "/hadoop/hdfs/namesecondary", "single") ] - Logger.info("Class: %s, Method: %s. Updating HDFS mount properties." % + self.logger.info("Class: %s, Method: %s. Updating HDFS mount properties." % (self.__class__.__name__, inspect.stack()[0][3])) self.updateMountProperties("hdfs-site", hdfs_mount_properties, configurations, services, hosts) @@ -217,7 +218,7 @@ class HDFSRecommender(service_advisor.ServiceAdvisor): hdfsSiteProperties["dfs.datanode.data.dir"] is not None: dataDirs = hdfsSiteProperties["dfs.datanode.data.dir"].split(",") - Logger.info("Class: %s, Method: %s. HDFS Data Dirs: %s" % + self.logger.info("Class: %s, Method: %s. HDFS Data Dirs: %s" % (self.__class__.__name__, inspect.stack()[0][3], str(dataDirs))) # dfs.datanode.du.reserved should be set to 10-15% of volume size @@ -242,7 +243,7 @@ class HDFSRecommender(service_advisor.ServiceAdvisor): if (not reservedSizeRecommendation) or (maxFreeVolumeSizeForHost and maxFreeVolumeSizeForHost < reservedSizeRecommendation): reservedSizeRecommendation = maxFreeVolumeSizeForHost - Logger.info("Class: %s, Method: %s. HDFS Datanode recommended reserved size: %d" % + self.logger.info("Class: %s, Method: %s. HDFS Datanode recommended reserved size: %d" % (self.__class__.__name__, inspect.stack()[0][3], reservedSizeRecommendation)) if reservedSizeRecommendation: @@ -290,11 +291,11 @@ class HDFSRecommender(service_advisor.ServiceAdvisor): ranger_hdfs_plugin_enabled = False if ranger_hdfs_plugin_enabled and 'ranger-hdfs-plugin-properties' in services['configurations'] and 'REPOSITORY_CONFIG_USERNAME' in services['configurations']['ranger-hdfs-plugin-properties']['properties']: - Logger.info("Setting HDFS Repo user for Ranger.") + self.logger.info("Setting HDFS Repo user for Ranger.") putRangerHDFSPluginProperty = self.putProperty(configurations, "ranger-hdfs-plugin-properties", services) putRangerHDFSPluginProperty("REPOSITORY_CONFIG_USERNAME",hdfs_user) else: - Logger.info("Not setting HDFS Repo user for Ranger.") + self.logger.info("Not setting HDFS Repo user for Ranger.") class HDFSValidator(service_advisor.ServiceAdvisor): @@ -590,7 +591,7 @@ class HDFSValidator(service_advisor.ServiceAdvisor): If Ranger service is present and the ranger plugin is enabled, check that the provider class is correctly set. :return: A list of configuration validation problems. """ - Logger.info("Class: %s, Method: %s. Checking if Ranger service is present and if the provider class is using the Ranger Authorizer." % + self.logger.info("Class: %s, Method: %s. Checking if Ranger service is present and if the provider class is using the Ranger Authorizer." % (self.__class__.__name__, inspect.stack()[0][3])) # We can not access property hadoop.security.authentication from the # other config (core-site). That's why we are using another heuristics here http://git-wip-us.apache.org/repos/asf/ambari/blob/9feb5d0f/ambari-server/src/main/resources/common-services/HIVE/2.1.0.3.0/service_advisor.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/HIVE/2.1.0.3.0/service_advisor.py b/ambari-server/src/main/resources/common-services/HIVE/2.1.0.3.0/service_advisor.py index c60339b..ef3e340 100644 --- a/ambari-server/src/main/resources/common-services/HIVE/2.1.0.3.0/service_advisor.py +++ b/ambari-server/src/main/resources/common-services/HIVE/2.1.0.3.0/service_advisor.py @@ -26,7 +26,6 @@ import socket import fnmatch -from resource_management.core.logger import Logger SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__)) STACKS_DIR = os.path.join(SCRIPT_DIR, '../../../stacks/') @@ -45,6 +44,8 @@ class HiveServiceAdvisor(service_advisor.ServiceAdvisor): self.as_super = super(HiveServiceAdvisor, self) self.as_super.__init__(*args, **kwargs) + self.initialize_logger("HiveServiceAdvisor") + # Always call these methods self.modifyMastersWithMultipleInstances() self.modifyCardinalitiesDict() @@ -118,7 +119,7 @@ class HiveServiceAdvisor(service_advisor.ServiceAdvisor): Entry point. Must be overriden in child class. """ - Logger.info("Class: %s, Method: %s. Recommending Service Configurations." % + self.logger.info("Class: %s, Method: %s. Recommending Service Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) recommender = HiveRecommender() @@ -136,7 +137,7 @@ class HiveServiceAdvisor(service_advisor.ServiceAdvisor): Validate configurations for the service. Return a list of errors. The code for this function should be the same for each Service Advisor. """ - Logger.info("Class: %s, Method: %s. Validating Configurations." % + self.logger.info("Class: %s, Method: %s. Validating Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) validator = HiveValidator() @@ -617,7 +618,7 @@ class HiveRecommender(service_advisor.ServiceAdvisor): def recommendHIVEConfigurationsFromHDP25(self, configurations, clusterData, services, hosts): - Logger.info("DBG: Invoked recommendHiveConfiguration") + self.logger.info("DBG: Invoked recommendHiveConfiguration") putHiveInteractiveEnvProperty = self.putProperty(configurations, "hive-interactive-env", services) putHiveInteractiveSiteProperty = self.putProperty(configurations, self.HIVE_INTERACTIVE_SITE, services) @@ -642,9 +643,9 @@ class HiveRecommender(service_advisor.ServiceAdvisor): if hive_tez_default_queue: putHiveInteractiveSiteProperty("hive.server2.tez.default.queues", hive_tez_default_queue) - Logger.debug("Updated 'hive.server2.tez.default.queues' config : '{0}'".format(hive_tez_default_queue)) + self.logger.debug("Updated 'hive.server2.tez.default.queues' config : '{0}'".format(hive_tez_default_queue)) else: - Logger.info("DBG: Setting 'num_llap_nodes' config's READ ONLY attribute as 'True'.") + self.logger.info("DBG: Setting 'num_llap_nodes' config's READ ONLY attribute as 'True'.") putHiveInteractiveEnvProperty('enable_hive_interactive', 'false') putHiveInteractiveEnvPropertyAttribute("num_llap_nodes", "read_only", "true") @@ -669,11 +670,11 @@ class HiveRecommender(service_advisor.ServiceAdvisor): ranger_hive_plugin_enabled = False if ranger_hive_plugin_enabled and 'ranger-hive-plugin-properties' in services['configurations'] and 'REPOSITORY_CONFIG_USERNAME' in services['configurations']['ranger-hive-plugin-properties']['properties']: - Logger.info("Setting Hive Repo user for Ranger.") + self.logger.info("Setting Hive Repo user for Ranger.") putRangerHivePluginProperty = self.putProperty(configurations, "ranger-hive-plugin-properties", services) putRangerHivePluginProperty("REPOSITORY_CONFIG_USERNAME",hive_user) else: - Logger.info("Not setting Hive Repo user for Ranger.") + self.logger.info("Not setting Hive Repo user for Ranger.") def getDBDriver(self, databaseType): @@ -1051,7 +1052,7 @@ class HiveValidator(service_advisor.ServiceAdvisor): capacity_scheduler_properties, received_as_key_value_pair = self.getCapacitySchedulerProperties(services) if not capacity_scheduler_properties: - Logger.warning("Couldn't retrieve 'capacity-scheduler' properties while doing validation checks for Hive Server Interactive.") + self.logger.warning("Couldn't retrieve 'capacity-scheduler' properties while doing validation checks for Hive Server Interactive.") return [] if hsi_site: @@ -1070,7 +1071,7 @@ class HiveValidator(service_advisor.ServiceAdvisor): "app to run".format(llap_queue_name, llap_queue_cap_perc, min_reqd_queue_cap_perc) validationItems.append({"config-name": "hive.llap.daemon.queue.name", "item": self.getErrorItem(errMsg1)}) else: - Logger.error("Couldn't retrieve '{0}' queue's capacity from 'capacity-scheduler' while doing validation checks for " + self.logger.error("Couldn't retrieve '{0}' queue's capacity from 'capacity-scheduler' while doing validation checks for " "Hive Server Interactive.".format(llap_queue_name)) # Validate that current selected queue in 'hive.llap.daemon.queue.name' state is not STOPPED. @@ -1081,10 +1082,10 @@ class HiveValidator(service_advisor.ServiceAdvisor): .format(llap_queue_name, llap_selected_queue_state) validationItems.append({"config-name": "hive.llap.daemon.queue.name","item": self.getErrorItem(errMsg2)}) else: - Logger.error("Couldn't retrieve '{0}' queue's state from 'capacity-scheduler' while doing validation checks for " + self.logger.error("Couldn't retrieve '{0}' queue's state from 'capacity-scheduler' while doing validation checks for " "Hive Server Interactive.".format(llap_queue_name)) else: - Logger.error("Couldn't retrieve 'hive.llap.daemon.queue.name' config from 'hive-interactive-site' while doing " + self.logger.error("Couldn't retrieve 'hive.llap.daemon.queue.name' config from 'hive-interactive-site' while doing " "validation checks for Hive Server Interactive.") # Validate that 'hive.server2.enable.doAs' config is not set to 'true' for Hive2. http://git-wip-us.apache.org/repos/asf/ambari/blob/9feb5d0f/ambari-server/src/main/resources/common-services/SLIDER/0.91.0.3.0/service_advisor.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/SLIDER/0.91.0.3.0/service_advisor.py b/ambari-server/src/main/resources/common-services/SLIDER/0.91.0.3.0/service_advisor.py index 6122f14..5614868 100644 --- a/ambari-server/src/main/resources/common-services/SLIDER/0.91.0.3.0/service_advisor.py +++ b/ambari-server/src/main/resources/common-services/SLIDER/0.91.0.3.0/service_advisor.py @@ -23,7 +23,6 @@ import os import traceback -from resource_management.core.logger import Logger SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__)) STACKS_DIR = os.path.join(SCRIPT_DIR, '../../../stacks/') @@ -43,6 +42,8 @@ class SliderServiceAdvisor(service_advisor.ServiceAdvisor): self.as_super = super(SliderServiceAdvisor, self) self.as_super.__init__(*args, **kwargs) + self.initialize_logger("SliderServiceAdvisor") + # Always call these methods self.modifyMastersWithMultipleInstances() self.modifyCardinalitiesDict() @@ -113,7 +114,7 @@ class SliderServiceAdvisor(service_advisor.ServiceAdvisor): Entry point. Must be overriden in child class. """ - Logger.info("Class: %s, Method: %s. Recommending Service Configurations." % + self.logger.info("Class: %s, Method: %s. Recommending Service Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) # Nothing to do @@ -125,7 +126,7 @@ class SliderServiceAdvisor(service_advisor.ServiceAdvisor): Validate configurations for the service. Return a list of errors. The code for this function should be the same for each Service Advisor. """ - Logger.info("Class: %s, Method: %s. Validating Configurations." % + self.logger.info("Class: %s, Method: %s. Validating Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) # Nothing to do http://git-wip-us.apache.org/repos/asf/ambari/blob/9feb5d0f/ambari-server/src/main/resources/common-services/SPARK/2.2.0/service_advisor.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/SPARK/2.2.0/service_advisor.py b/ambari-server/src/main/resources/common-services/SPARK/2.2.0/service_advisor.py index ee803b0..b876cd7 100644 --- a/ambari-server/src/main/resources/common-services/SPARK/2.2.0/service_advisor.py +++ b/ambari-server/src/main/resources/common-services/SPARK/2.2.0/service_advisor.py @@ -23,7 +23,6 @@ import os import traceback -from resource_management.core.logger import Logger SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__)) STACKS_DIR = os.path.join(SCRIPT_DIR, '../../../stacks/') @@ -42,6 +41,8 @@ class SparkServiceAdvisor(service_advisor.ServiceAdvisor): self.as_super = super(SparkServiceAdvisor, self) self.as_super.__init__(*args, **kwargs) + self.initialize_logger("SparkServiceAdvisor") + # Always call these methods self.modifyMastersWithMultipleInstances() self.modifyCardinalitiesDict() @@ -120,7 +121,7 @@ class SparkServiceAdvisor(service_advisor.ServiceAdvisor): Entry point. Must be overriden in child class. """ - Logger.info("Class: %s, Method: %s. Recommending Service Configurations." % + self.logger.info("Class: %s, Method: %s. Recommending Service Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) recommender = SparkRecommender() @@ -134,7 +135,7 @@ class SparkServiceAdvisor(service_advisor.ServiceAdvisor): Validate configurations for the service. Return a list of errors. The code for this function should be the same for each Service Advisor. """ - Logger.info("Class: %s, Method: %s. Validating Configurations." % + self.logger.info("Class: %s, Method: %s. Validating Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) validator = SparkValidator() http://git-wip-us.apache.org/repos/asf/ambari/blob/9feb5d0f/ambari-server/src/main/resources/common-services/TEZ/0.9.0.3.0/service_advisor.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/TEZ/0.9.0.3.0/service_advisor.py b/ambari-server/src/main/resources/common-services/TEZ/0.9.0.3.0/service_advisor.py index cc84cc4..d71983f 100644 --- a/ambari-server/src/main/resources/common-services/TEZ/0.9.0.3.0/service_advisor.py +++ b/ambari-server/src/main/resources/common-services/TEZ/0.9.0.3.0/service_advisor.py @@ -26,7 +26,6 @@ import socket import fnmatch -from resource_management.core.logger import Logger SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__)) STACKS_DIR = os.path.join(SCRIPT_DIR, '../../../stacks/') @@ -45,6 +44,8 @@ class TezServiceAdvisor(service_advisor.ServiceAdvisor): self.as_super = super(TezServiceAdvisor, self) self.as_super.__init__(*args, **kwargs) + self.initialize_logger("TezServiceAdvisor") + # Always call these methods self.modifyMastersWithMultipleInstances() self.modifyCardinalitiesDict() @@ -115,7 +116,7 @@ class TezServiceAdvisor(service_advisor.ServiceAdvisor): Entry point. Must be overriden in child class. """ - Logger.info("Class: %s, Method: %s. Recommending Service Configurations." % + self.logger.info("Class: %s, Method: %s. Recommending Service Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) recommender = TezRecommender() @@ -131,7 +132,7 @@ class TezServiceAdvisor(service_advisor.ServiceAdvisor): Validate configurations for the service. Return a list of errors. The code for this function should be the same for each Service Advisor. """ - Logger.info("Class: %s, Method: %s. Validating Configurations." % + self.logger.info("Class: %s, Method: %s. Validating Configurations." % (self.__class__.__name__, inspect.stack()[0][3])) validator = TezValidator() @@ -315,7 +316,7 @@ class TezRecommender(service_advisor.ServiceAdvisor): tez_jvm_updated_opts = tez_jvm_opts + jvmGCParams + "{{heap_dump_opts}}" putTezProperty('tez.am.launch.cmd-opts', tez_jvm_updated_opts) putTezProperty('tez.task.launch.cmd-opts', tez_jvm_updated_opts) - Logger.info("Updated 'tez-site' config 'tez.task.launch.cmd-opts' and 'tez.am.launch.cmd-opts' as " + self.logger.info("Updated 'tez-site' config 'tez.task.launch.cmd-opts' and 'tez.am.launch.cmd-opts' as " ": {0}".format(tez_jvm_updated_opts))