Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 0047e5d4c -> bbf4e9692
  refs/heads/4.x-HBase-1.0 4ca06a39e -> 06aca0f2c
  refs/heads/4.x-HBase-1.1 19fa69e4c -> 9c16db98c
  refs/heads/master a0504fba1 -> 96a1d5528


Add environment variables to control the location of the queryserver .log, 
.out, and .pid file. Also update the name of all files to '${USER}-queryserver'.

Signed-off-by: Josh Elser <els...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/96a1d552
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/96a1d552
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/96a1d552

Branch: refs/heads/master
Commit: 96a1d55283f8d1c0f18494d8bce1f8efb5c46c96
Parents: a0504fb
Author: Rob Leidle <lei...@amazon.com>
Authored: Mon May 2 13:40:32 2016 -0700
Committer: Josh Elser <els...@apache.org>
Committed: Tue May 10 21:40:58 2016 -0400

----------------------------------------------------------------------
 bin/queryserver.py | 34 +++++++++++++---------------------
 1 file changed, 13 insertions(+), 21 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/phoenix/blob/96a1d552/bin/queryserver.py
----------------------------------------------------------------------
diff --git a/bin/queryserver.py b/bin/queryserver.py
index c80e629..57ca371 100755
--- a/bin/queryserver.py
+++ b/bin/queryserver.py
@@ -74,15 +74,11 @@ else:
 hbase_config_path = phoenix_utils.hbase_conf_dir
 hadoop_config_path = phoenix_utils.hadoop_conf
 
-# default paths ## TODO: add windows support
-java_home = os.getenv('JAVA_HOME')
-hbase_pid_dir = os.path.join(tempfile.gettempdir(), 'phoenix')
-phoenix_log_dir = os.path.join(tempfile.gettempdir(), 'phoenix')
-phoenix_file_basename = 'phoenix-%s-server' % getpass.getuser()
+# TODO: add windows support
+phoenix_file_basename = '%s-queryserver' % getpass.getuser()
 phoenix_log_file = '%s.log' % phoenix_file_basename
 phoenix_out_file = '%s.out' % phoenix_file_basename
 phoenix_pid_file = '%s.pid' % phoenix_file_basename
-opts = os.getenv('PHOENIX_QUERYSERVER_OPTS', '')
 
 # load hbase-env.??? to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR
 hbase_env_path = None
@@ -104,24 +100,20 @@ if os.path.isfile(hbase_env_path):
         (k, _, v) = x.partition('=')
         hbase_env[k.strip()] = v.strip()
 
-if hbase_env.has_key('JAVA_HOME'):
-    java_home = hbase_env['JAVA_HOME']
-if hbase_env.has_key('HBASE_PID_DIR'):
-    hbase_pid_dir = hbase_env['HBASE_PID_DIR']
-if hbase_env.has_key('HBASE_LOG_DIR'):
-    phoenix_log_dir = hbase_env['HBASE_LOG_DIR']
-if hbase_env.has_key('PHOENIX_QUERYSERVER_OPTS'):
-    opts = hbase_env['PHOENIX_QUERYSERVER_OPTS']
-
-log_file_path = os.path.join(phoenix_log_dir, phoenix_log_file)
-out_file_path = os.path.join(phoenix_log_dir, phoenix_out_file)
-pid_file_path = os.path.join(hbase_pid_dir, phoenix_pid_file)
-
+java_home = hbase_env.get('JAVA_HOME') or os.getenv('JAVA_HOME')
 if java_home:
     java = os.path.join(java_home, 'bin', 'java')
 else:
     java = 'java'
 
+tmp_dir = os.path.join(tempfile.gettempdir(), 'phoenix')
+opts = os.getenv('PHOENIX_QUERYSERVER_OPTS') or 
hbase_env.get('PHOENIX_QUERYSERVER_OPTS') or ''
+pid_dir = os.getenv('PHOENIX_QUERYSERVER_PID_DIR') or 
hbase_env.get('HBASE_PID_DIR') or tmp_dir
+log_dir = os.getenv('PHOENIX_QUERYSERVER_LOG_DIR') or 
hbase_env.get('HBASE_LOG_DIR') or tmp_dir
+pid_file_path = os.path.join(pid_dir, phoenix_pid_file)
+log_file_path = os.path.join(log_dir, phoenix_log_file)
+out_file_path = os.path.join(log_dir, phoenix_out_file)
+
 #    " -Xdebug -Xrunjdwp:transport=dt_socket,address=5005,server=y,suspend=n " 
+ \
 #    " -XX:+UnlockCommercialFeatures -XX:+FlightRecorder 
-XX:FlightRecorderOptions=defaultrecording=true,dumponexit=true" + \
 
@@ -137,7 +129,7 @@ java_cmd = '%(java)s -cp ' + hbase_config_path + os.pathsep 
+ hadoop_config_path
     " org.apache.phoenix.queryserver.server.Main " + args
 
 if command == 'makeWinServiceDesc':
-    cmd = java_cmd % {'java': java, 'root_logger': 'INFO,DRFA,console', 
'log_dir': phoenix_log_dir, 'log_file': phoenix_log_file}
+    cmd = java_cmd % {'java': java, 'root_logger': 'INFO,DRFA,console', 
'log_dir': log_dir, 'log_file': phoenix_log_file}
     slices = cmd.split(' ')
 
     print "<service>"
@@ -168,7 +160,7 @@ if command == 'start':
         with context:
             # this block is the main() for the forked daemon process
             child = None
-            cmd = java_cmd % {'java': java, 'root_logger': 'INFO,DRFA', 
'log_dir': phoenix_log_dir, 'log_file': phoenix_log_file}
+            cmd = java_cmd % {'java': java, 'root_logger': 'INFO,DRFA', 
'log_dir': log_dir, 'log_file': phoenix_log_file}
 
             # notify the child when we're killed
             def handler(signum, frame):

Reply via email to