Repository: ambari Updated Branches: refs/heads/branch-2.6 65535fbb1 -> c94611285
AMBARI-21909. LLAP concurrency (hive.server2.tez.sessions.per.default.queue) max calculated value should not be less than its current value. Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/c9461128 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/c9461128 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/c9461128 Branch: refs/heads/branch-2.6 Commit: c94611285200c297a51e2b37805ff954f625429d Parents: 65535fb Author: Swapan Shridhar <[email protected]> Authored: Thu Sep 7 22:48:01 2017 -0700 Committer: Swapan Shridhar <[email protected]> Committed: Thu Sep 7 22:48:01 2017 -0700 ---------------------------------------------------------------------- .../src/main/resources/stacks/HDP/2.5/services/stack_advisor.py | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/c9461128/ambari-server/src/main/resources/stacks/HDP/2.5/services/stack_advisor.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.5/services/stack_advisor.py b/ambari-server/src/main/resources/stacks/HDP/2.5/services/stack_advisor.py index 4e43f8e..be615db 100644 --- a/ambari-server/src/main/resources/stacks/HDP/2.5/services/stack_advisor.py +++ b/ambari-server/src/main/resources/stacks/HDP/2.5/services/stack_advisor.py @@ -1295,6 +1295,11 @@ class HDP25StackAdvisor(HDP24StackAdvisor): putHiveInteractiveSiteProperty('hive.server2.tez.sessions.per.default.queue', long(llap_concurrency)) putHiveInteractiveSitePropertyAttribute('hive.server2.tez.sessions.per.default.queue', "minimum", min_llap_concurrency) + # Check if 'max_llap_concurreny' < 'llap_concurrency'. + if max_llap_concurreny < llap_concurrency: + self.logger.info("DBG: Adjusting 'max_llap_concurreny' to : {0}, based on 'llap_concurrency' : {1} and " + "earlier 'max_llap_concurreny' : {2}. ".format(llap_concurrency, llap_concurrency, max_llap_concurreny)) + max_llap_concurreny = llap_concurrency putHiveInteractiveSitePropertyAttribute('hive.server2.tez.sessions.per.default.queue', "maximum", long(max_llap_concurreny)) num_llap_nodes = long(num_llap_nodes)
