AMBARI-19636: Provide default values for Kafka nofile and nproc limit properties (dili)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/b2d78ac5 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/b2d78ac5 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/b2d78ac5 Branch: refs/heads/branch-dev-patch-upgrade Commit: b2d78ac5f3136bc9d55e3f8806726146278bd654 Parents: 918fd59 Author: Di Li <d...@apache.org> Authored: Mon Jan 23 12:03:55 2017 -0500 Committer: Di Li <d...@apache.org> Committed: Mon Jan 23 12:03:55 2017 -0500 ---------------------------------------------------------------------- .../common-services/KAFKA/0.8.1/package/scripts/params.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/b2d78ac5/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py index 6c7ff69..1d3a195 100644 --- a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py +++ b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py @@ -76,8 +76,8 @@ limits_conf_dir = "/etc/security/limits.d" # Used while upgrading the stack in a kerberized cluster and running kafka-acls.sh zookeeper_connect = default("/configurations/kafka-broker/zookeeper.connect", None) -kafka_user_nofile_limit = config['configurations']['kafka-env']['kafka_user_nofile_limit'] -kafka_user_nproc_limit = config['configurations']['kafka-env']['kafka_user_nproc_limit'] +kafka_user_nofile_limit = default('/configurations/kafka-env/kafka_user_nofile_limit', 128000) +kafka_user_nproc_limit = default('/configurations/kafka-env/kafka_user_nproc_limit', 65536) # parameters for 2.2+ if stack_version_formatted and check_stack_feature(StackFeature.ROLLING_UPGRADE, stack_version_formatted):