This is an automated email from the ASF dual-hosted git repository.

amagyar pushed a commit to branch trunk
in repository

commit 2d125c91254b81475cf1b429031b6b66c75808e7
Author: Doroszlai, Attila <>
AuthorDate: Mon Mar 26 10:06:42 2018 +0200

    Tweak whitespace
 .../src/main/resources/scripts/          | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git a/ambari-server/src/main/resources/scripts/ 
index 75ced40..12d9156 100644
--- a/ambari-server/src/main/resources/scripts/
+++ b/ambari-server/src/main/resources/scripts/
@@ -47,7 +47,7 @@ PROPERTIES = 'properties'
 ATTRIBUTES = 'properties_attributes'
 CLUSTERS = 'Clusters'
 DESIRED_CONFIGS = 'desired_configs'
+SERVICE_CONFIG_NOTE = 'service_config_version_note'
 TYPE = 'type'
 TAG = 'tag'
 ITEMS = 'items'
@@ -100,7 +100,7 @@ def get_config_tag(cluster, config_type, accessor):
     raise Exception('"{0}" not found in server response. 
Response:\n{1}'.format(config_type, response))
   return current_config_tag
-def create_new_desired_config(cluster, config_type, properties, attributes, 
+def create_new_desired_config(cluster, config_type, properties, attributes, 
accessor, version_note):
   new_tag = TAG_PREFIX + str(int(time.time() * 1000000))
   new_config = {
     CLUSTERS: {
@@ -129,9 +129,9 @@ def get_current_config(cluster, config_type, accessor):
   current_config = config_by_tag[ITEMS][0]
   return current_config[PROPERTIES], current_config.get(ATTRIBUTES, {})
-def update_config(cluster, config_type, config_updater, accessor,version_note):
+def update_config(cluster, config_type, config_updater, accessor, 
   properties, attributes = config_updater(cluster, config_type, accessor)
-  create_new_desired_config(cluster, config_type, properties, attributes, 
+  create_new_desired_config(cluster, config_type, properties, attributes, 
accessor, version_note)
 def update_specific_property(config_name, config_value):
   def update(cluster, config_type, accessor):
@@ -217,7 +217,7 @@ def get_config(cluster, config_type, accessor, output):
     config[ATTRIBUTES] = attributes
-def set_properties(cluster, config_type, args, accessor,version_note):
+def set_properties(cluster, config_type, args, accessor, version_note):'### Performing "set":')
   if len(args) == 1:
@@ -236,10 +236,10 @@ def set_properties(cluster, config_type, args, 
     config_value = args[1]
     updater = update_specific_property(config_name, config_value)'### new property - "{0}":"{1}"'.format(config_name, 
-  update_config(cluster, config_type, updater, accessor,version_note)
+  update_config(cluster, config_type, updater, accessor, version_note)
   return 0
-def delete_properties(cluster, config_type, args, accessor,version_note):
+def delete_properties(cluster, config_type, args, accessor, version_note):'### Performing "delete":')
   if len(args) == 0:
     logger.error("Not enough arguments. Expected config key.")
@@ -247,7 +247,7 @@ def delete_properties(cluster, config_type, args, 
   config_name = args[0]'### on property "{0}"'.format(config_name))
-  update_config(cluster, config_type, delete_specific_property(config_name), 
+  update_config(cluster, config_type, delete_specific_property(config_name), 
accessor, version_note)
   return 0
@@ -278,7 +278,7 @@ def main():
   parser.add_option("-l", "--host", dest="host", help="Server external host 
   parser.add_option("-n", "--cluster", dest="cluster", help="Name given to 
cluster. Ex: 'c1'")
   parser.add_option("-c", "--config-type", dest="config_type", help="One of 
the various configuration types in Ambari. Ex: core-site, hdfs-site, 
mapred-queue-acls, etc.")
-  parser.add_option("-b", "--version-note", dest="version_note",default="", 
help="Version change notes which will help to know what has been changed in 
this config , this value is optional and is used for action <set> and <delete>")
+  parser.add_option("-b", "--version-note", dest="version_note", default="", 
help="Version change notes which will help to know what has been changed in 
this config. This value is optional and is used for actions <set> and 
   config_options_group = OptionGroup(parser, "To specify property(s) please 
use \"-f\" OR \"-k\" and \"-v'\"")
   config_options_group.add_option("-f", "--file", dest="file", help="File 
where entire configurations are saved to, or read from. Supported extensions 
(.xml, .json>)")
@@ -344,7 +344,7 @@ def main():
       action_args = [options.file]
       action_args = [options.key, options.value]
-    return set_properties(cluster, config_type, action_args, 
+    return set_properties(cluster, config_type, action_args, accessor, 
   elif action == GET_ACTION:
     if options.file:
@@ -358,7 +358,7 @@ def main():
       parser.error("You should use option (-k) to set property name witch will 
be deleted")
       action_args = [options.key]
-    return delete_properties(cluster, config_type, action_args, 
+    return delete_properties(cluster, config_type, action_args, accessor, 
     logger.error('Action "{0}" is not supported. Supported actions: "get", 
"set", "delete".'.format(action))
     return -1

To stop receiving notification emails like this one, please contact

Reply via email to