|
@@ -44,6 +44,7 @@ LOG = logging.getLogger(__name__)
|
|
|
|
|
|
|
|
STARTUP_DEADLINE = 60.0
|
|
STARTUP_DEADLINE = 60.0
|
|
|
CLEANUP_TMP_DIR = os.environ.get('MINI_CLUSTER_CLEANUP', 'true')
|
|
CLEANUP_TMP_DIR = os.environ.get('MINI_CLUSTER_CLEANUP', 'true')
|
|
|
|
|
+TEST_HDFS_TMP_DIR = os.environ.get('TEST_HDFS_TMP_DIR')
|
|
|
|
|
|
|
|
|
|
|
|
|
def is_live_cluster():
|
|
def is_live_cluster():
|
|
@@ -83,7 +84,7 @@ class PseudoHdfs4(object):
|
|
|
"""Run HDFS and MR2 locally, in pseudo-distributed mode"""
|
|
"""Run HDFS and MR2 locally, in pseudo-distributed mode"""
|
|
|
|
|
|
|
|
def __init__(self):
|
|
def __init__(self):
|
|
|
- self._tmpdir = tempfile.mkdtemp(prefix='tmp_hue_')
|
|
|
|
|
|
|
+ self._tmpdir = tempfile.mkdtemp(prefix='tmp_hue_', dir=TEST_HDFS_TMP_DIR)
|
|
|
os.chmod(self._tmpdir, 0755)
|
|
os.chmod(self._tmpdir, 0755)
|
|
|
self._superuser = getpass.getuser()
|
|
self._superuser = getpass.getuser()
|
|
|
self.fs_prefix = None
|
|
self.fs_prefix = None
|