Repository: incubator-slider Updated Branches: refs/heads/develop 7777ad53a -> 8609f16aa
SLIDER-287 Allow more parameters to be passed to HBase thrift gateway Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/8609f16a Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/8609f16a Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/8609f16a Branch: refs/heads/develop Commit: 8609f16aacf69ac4463299a194c335669e2fb207 Parents: 7777ad5 Author: tedyu <[email protected]> Authored: Wed Dec 17 11:01:19 2014 -0800 Committer: tedyu <[email protected]> Committed: Wed Dec 17 11:01:19 2014 -0800 ---------------------------------------------------------------------- app-packages/hbase/package/scripts/hbase_service.py | 14 +++++++++++++- app-packages/hbase/package/scripts/params.py | 6 ++++++ 2 files changed, 19 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/8609f16a/app-packages/hbase/package/scripts/hbase_service.py ---------------------------------------------------------------------- diff --git a/app-packages/hbase/package/scripts/hbase_service.py b/app-packages/hbase/package/scripts/hbase_service.py index db663b8..e32e68d 100644 --- a/app-packages/hbase/package/scripts/hbase_service.py +++ b/app-packages/hbase/package/scripts/hbase_service.py @@ -38,7 +38,19 @@ def hbase_service( if name == 'rest': daemon_cmd = format("{daemon_cmd} -p {rest_port}") elif name == 'thrift': - daemon_cmd = format("{daemon_cmd} -p {thrift_port}") + queue = "" + if not thrift_queue == "": + queue = " -q {thrift_queue}" + workers = "" + if not thrift_workers == "": + workers = " -w {thrift_workers}" + compact = "" + if not thrift_compact == "": + compact = " -c" + framed = "" + if not thrift_framed == "": + framed = " -f" + daemon_cmd = format("{daemon_cmd} -p {thrift_port}" + queue + workers + compact + framed) elif name == 'thrift2': daemon_cmd = format("{daemon_cmd} -p {thrift2_port}") no_op_test = format("ls {pid_file} >/dev/null 2>&1 && ps `cat {pid_file}` >/dev/null 2>&1") http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/8609f16a/app-packages/hbase/package/scripts/params.py ---------------------------------------------------------------------- diff --git a/app-packages/hbase/package/scripts/params.py b/app-packages/hbase/package/scripts/params.py index 33e2bbf..9cbbe18 100644 --- a/app-packages/hbase/package/scripts/params.py +++ b/app-packages/hbase/package/scripts/params.py @@ -62,6 +62,12 @@ ganglia_server_port = default('/configurations/global/ganglia_server_port', '866 rest_port = config['configurations']['global']['hbase_rest_port'] thrift_port = config['configurations']['global']['hbase_thrift_port'] +thrift_queue = config['configurations']['global']['hbase_thrift_queue'] +if is_empty(thrift_queue): + thrift_queue = "" +thrift_workers = config['configurations']['global']['hbase_thrift_workers'] +thrift_compact = config['configurations']['global']['hbase_thrift_compact'] +thrift_framed = config['configurations']['global']['hbase_thrift_framed'] thrift2_port = config['configurations']['global']['hbase_thrift2_port'] if security_enabled:
