Browse Source

[beeswax] Cleared all old references to Beeswax daemon

Romain Rigaux 11 years ago
parent
commit
851cd1fda0

+ 6 - 2
apps/beeswax/src/beeswax/management/commands/close_queries.py

@@ -19,7 +19,7 @@ from django.core.management.base import BaseCommand
 
 from datetime import datetime,  timedelta
 
-from beeswax.models import QueryHistory, BeeswaxQueryHistory
+from beeswax.models import QueryHistory
 from beeswax.server import dbms
 
 
@@ -53,7 +53,11 @@ class Command(BaseCommand):
     import beeswax
     from beeswax import conf
     from beeswax import hive_site
-    beeswax.conf.BEESWAX_HIVE_CONF_DIR.set_for_testing(os.environ['HIVE_CONF_DIR'])
+    try:
+      beeswax.conf.HIVE_CONF_DIR.set_for_testing(os.environ['HIVE_CONF_DIR'])
+    except:
+      self.stdout.write('Did you export HIVE_CONF_DIR=/etc/hive/conf?\n')
+      raise
 
     hive_site.reset()
     hive_site.get_conf()

+ 5 - 1
apps/beeswax/src/beeswax/management/commands/close_sessions.py

@@ -53,7 +53,11 @@ class Command(BaseCommand):
     import beeswax
     from beeswax import conf
     from beeswax import hive_site
-    beeswax.conf.BEESWAX_HIVE_CONF_DIR.set_for_testing(os.environ['HIVE_CONF_DIR'])
+    try:
+      beeswax.conf.HIVE_CONF_DIR.set_for_testing(os.environ['HIVE_CONF_DIR'])
+    except:
+      self.stdout.write('Did you export HIVE_CONF_DIR=/etc/hive/conf?\n')
+      raise
 
     hive_site.reset()
     hive_site.get_conf()