You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by tb...@apache.org on 2016/05/17 13:14:04 UTC
ambari git commit: AMBARI-16693 - Atlas Server script error during
upgrade.
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 <tb...@hortonworks.com>
Authored: Tue May 17 09:13:39 2016 -0400
Committer: tbeerbower <tb...@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)