Repository: ambari Updated Branches: refs/heads/trunk 0d5b881c4 -> ea08b971c
AMBARI-16693 - Atlas Server script error during upgrade. Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/ea08b971 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/ea08b971 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/ea08b971 Branch: refs/heads/trunk Commit: ea08b971c370a784e47977cc4f6358d86f6b6f7d Parents: 0d5b881 Author: tbeerbower <tbeerbo...@hortonworks.com> Authored: Tue May 17 09:13:39 2016 -0400 Committer: tbeerbower <tbeerbo...@hortonworks.com> Committed: Tue May 17 09:13:55 2016 -0400 ---------------------------------------------------------------------- .../common-services/ATLAS/0.1.0.2.3/package/scripts/params.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/ea08b971/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py index fb4a55f..b33a956 100644 --- a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py +++ b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py @@ -136,7 +136,8 @@ else: # kafka kafka_bootstrap_servers = "" -kafka_broker_hosts = config['clusterHostInfo']['kafka_broker_hosts'] +kafka_broker_hosts = default('/clusterHostInfo/kafka_broker_hosts', []) + if not len(kafka_broker_hosts) == 0: kafka_broker_port = default("/configurations/kafka-broker/port", 6667) kafka_bootstrap_servers = kafka_broker_hosts[0] + ":" + str(kafka_broker_port)
