Repository: ambari Updated Branches: refs/heads/branch-2.6 e845f41a7 -> a21dc6d89
AMBARI-21793. Add support for variables used by Knox topology template (Sandeep More via smohanty) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/a21dc6d8 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/a21dc6d8 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/a21dc6d8 Branch: refs/heads/branch-2.6 Commit: a21dc6d89a8243a34bf5fdc9df089bdfcaf40443 Parents: e845f41 Author: Sumit Mohanty <smoha...@hortonworks.com> Authored: Thu Aug 24 16:55:14 2017 -0700 Committer: Sumit Mohanty <smoha...@hortonworks.com> Committed: Thu Aug 24 17:01:13 2017 -0700 ---------------------------------------------------------------------- .../0.5.0.2.2/package/scripts/params_linux.py | 91 +++++++++++++++++++- 1 file changed, 90 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/a21dc6d8/ambari-server/src/main/resources/common-services/KNOX/0.5.0.2.2/package/scripts/params_linux.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/KNOX/0.5.0.2.2/package/scripts/params_linux.py b/ambari-server/src/main/resources/common-services/KNOX/0.5.0.2.2/package/scripts/params_linux.py index c9b229f..7f2101d 100644 --- a/ambari-server/src/main/resources/common-services/KNOX/0.5.0.2.2/package/scripts/params_linux.py +++ b/ambari-server/src/main/resources/common-services/KNOX/0.5.0.2.2/package/scripts/params_linux.py @@ -221,6 +221,12 @@ if type(webhcat_server_hosts) is list: else: webhcat_server_host = webhcat_server_hosts +hive_scheme = 'http' +webhcat_scheme = 'http' + +hbase_master_scheme = 'http' +hbase_master_ui_port = default('/configurations/hbase-site/hbase.master.info.port', "16010"); + hbase_master_port = default('/configurations/hbase-site/hbase.rest.port', "8080") hbase_master_hosts = default("/clusterHostInfo/hbase_master_hosts", None) if type(hbase_master_hosts) is list: @@ -228,17 +234,100 @@ if type(hbase_master_hosts) is list: else: hbase_master_host = hbase_master_hosts +# +# Oozie +# +oozie_https_port = None +oozie_scheme = 'http' +oozie_server_port = "11000" oozie_server_hosts = default("/clusterHostInfo/oozie_server", None) + if type(oozie_server_hosts) is list: oozie_server_host = oozie_server_hosts[0] else: oozie_server_host = oozie_server_hosts has_oozie = not oozie_server_host == None -oozie_server_port = "11000" if has_oozie: oozie_server_port = get_port_from_url(config['configurations']['oozie-site']['oozie.base.url']) + oozie_https_port = default("/configurations/oozie-site/oozie.https.port", None) + +if oozie_https_port is not None: + oozie_scheme = 'https' + oozie_server_port = oozie_https_port + +# +# Falcon +# +falcon_server_hosts = default("/clusterHostInfo/falcon_server_hosts", None) +if type(falcon_server_hosts) is list: + falcon_server_host = falcon_server_hosts[0] +else: + falcon_server_host = falcon_server_hosts + +falcon_scheme = 'http' +has_falcon = not falcon_server_host == None +falcon_server_port = "15000" + +if has_falcon: + falcon_server_port = config['configurations']['falcon-env']['falcon_port'] + +# +# Solr +# +solr_scheme='http' +solr_server_hosts = default("/clusterHostInfo/solr_hosts", None) +if type(solr_server_hosts ) is list: + solr_host = solr_server_hosts[0] +else: + solr_host = solr_server_hosts +solr_port=default("/configuration/solr/solr-env/solr_port","8983") + +# +# Spark +# +spark_scheme = 'http' +spark_historyserver_hosts = default("/clusterHostInfo/spark_jobhistoryserver_hosts", None) +if type(spark_historyserver_hosts) is list: + spark_historyserver_host = spark_historyserver_hosts[0] +else: + spark_historyserver_host = spark_historyserver_hosts +spark_historyserver_ui_port = default("/configurations/spark-defaults/spark.history.ui.port", "18080") + + +# +# JobHistory mapreduce +# +mr_scheme='http' +mr_historyserver_address = default("/configurations/mapred-site/mapreduce.jobhistory.webapp.address", None) + +# +# Yarn nodemanager +# +nodeui_scheme= 'http' +nodeui_port = "8042" +nm_hosts = default("/clusterHostInfo/nm_hosts", None) +if type(nm_hosts) is list: + nm_host = nm_hosts[0] +else: + nm_host = nm_hosts + +has_yarn = default("/configurations/yarn-site", None ) +if has_yarn and 'yarn.nodemanager.webapp.address' in config['configurations']['yarn-site']: + nodeui_port = get_port_from_url(config['configurations']['yarn-site']['yarn.nodemanager.webapp.address']) + + +# +# Spark Thrift UI +# +spark_thriftserver_scheme = 'http' +spark_thriftserver_ui_port = 4039 +spark_thriftserver_hosts = default("/clusterHostInfo/spark_thriftserver_hosts", None) +if type(spark_thriftserver_hosts) is list: + spark_thriftserver_host = spark_thriftserver_hosts[0] +else: + spark_thriftserver_host = spark_thriftserver_hosts # Knox managed properties knox_managed_pid_symlink= format('{stack_root}/current/knox-server/pids')
