Repository: incubator-slider Updated Branches: refs/heads/develop 4e8e92e11 -> 72983bb05
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/72983bb0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/72983bb0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/72983bb0 Branch: refs/heads/develop Commit: 72983bb0513910cce6de86241c7ae01c9645bab3 Parents: 4e8e92e Author: tedyu <[email protected]> Authored: Fri Dec 19 12:22:36 2014 -0800 Committer: tedyu <[email protected]> Committed: Fri Dec 19 12:22:36 2014 -0800 ---------------------------------------------------------------------- app-packages/hbase/package/scripts/hbase_service.py | 14 +++++++++++++- app-packages/hbase/package/scripts/params.py | 4 ++++ 2 files changed, 17 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/72983bb0/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 e32e68d..a963685 100644 --- a/app-packages/hbase/package/scripts/hbase_service.py +++ b/app-packages/hbase/package/scripts/hbase_service.py @@ -50,7 +50,19 @@ def hbase_service( framed = "" if not thrift_framed == "": framed = " -f" - daemon_cmd = format("{daemon_cmd} -p {thrift_port}" + queue + workers + compact + framed) + infoport = "" + if not thrift_infoport == "": + infoport = " --infoport {thrift_infoport}" + keepalive_sec = "" + if not thrift_keepalive_sec == "": + keepalive_sec = " --keepAliveSec {thrift_keepalive_sec}" + minWorkers = "" + if not thrift_minWorkers == "": + minWorkers = " --minWorkers {thrift_minWorkers}" + nonblocking = "" + if not thrift_nonblocking == "": + nonblocking = " -nonblocking" + daemon_cmd = format("{daemon_cmd} -p {thrift_port}" + queue + workers + compact + framed + infoport + keepalive_sec + minWorkers + nonblocking) 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/72983bb0/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 9cbbe18..d370d15 100644 --- a/app-packages/hbase/package/scripts/params.py +++ b/app-packages/hbase/package/scripts/params.py @@ -62,6 +62,10 @@ 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_keepalive_sec = config['configurations']['global']['hbase_thrift_keepalive_sec'] +thrift_infoport = config['configurations']['global']['hbase_thrift_infoport'] +thrift_nonblocking = config['configurations']['global']['hbase_thrift_nonblocking'] +thrift_minWorkers = config['configurations']['global']['hbase_thrift_minWorkers'] thrift_queue = config['configurations']['global']['hbase_thrift_queue'] if is_empty(thrift_queue): thrift_queue = ""
