You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sm...@apache.org on 2016/09/09 18:37:49 UTC
ambari git commit: AMBARI-18340. Kafka acls setup is failing as part
of atlas start (patch-II)
Repository: ambari
Updated Branches:
refs/heads/branch-2.5 d4d182859 -> 79afcb9a2
AMBARI-18340. Kafka acls setup is failing as part of atlas start (patch-II)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/79afcb9a
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/79afcb9a
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/79afcb9a
Branch: refs/heads/branch-2.5
Commit: 79afcb9a2789d7f8be1bc32b8ca5a36ad62516e7
Parents: d4d1828
Author: Sumit Mohanty <sm...@hortonworks.com>
Authored: Fri Sep 9 11:37:27 2016 -0700
Committer: Sumit Mohanty <sm...@hortonworks.com>
Committed: Fri Sep 9 11:37:27 2016 -0700
----------------------------------------------------------------------
.../common-services/ATLAS/0.1.0.2.3/package/scripts/params.py | 2 +-
.../ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/79afcb9a/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 91b7ae2..32e1510 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
@@ -249,7 +249,7 @@ host_with_kafka = hostname in hosts_with_kafka
ranger_tagsync_hosts = default("/clusterHostInfo/ranger_tagsync_hosts", [])
has_ranger_tagsync = len(ranger_tagsync_hosts) > 0
-ranger_user = default('/configurations/ranger-env/ranger_user', None)
+rangertagsync_user = "rangertagsync"
kafka_keytab = default('/configurations/kafka-env/kafka_keytab', None)
kafka_principal_name = default('/configurations/kafka-env/kafka_principal_name', None)
http://git-wip-us.apache.org/repos/asf/ambari/blob/79afcb9a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2
index ca7a85d..6a2edc6 100644
--- a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2
+++ b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2
@@ -37,5 +37,5 @@ create_topic ATLAS_ENTITIES
{{kafka_home}}/bin/kafka-acls.sh --authorizer-properties zookeeper.connect={{kafka_zk_endpoint}} --add --topic ATLAS_ENTITIES --allow-principal User:{{metadata_user}} --producer
{% if has_ranger_tagsync %}
-{{kafka_home}}/bin/kafka-acls.sh --authorizer-properties zookeeper.connect={{kafka_zk_endpoint}} --add --topic ATLAS_ENTITIES --allow-principal User:{{ranger_user}} --consumer --group ranger_entities_consumer
+{{kafka_home}}/bin/kafka-acls.sh --authorizer-properties zookeeper.connect={{kafka_zk_endpoint}} --add --topic ATLAS_ENTITIES --allow-principal User:{{rangertagsync_user}} --consumer --group ranger_entities_consumer
{% endif %}
\ No newline at end of file