Skip to content
Snippets Groups Projects
Commit b49c4283 authored by root's avatar root
Browse files

Added environment variables to check_hadoop_df

parent a8ee7e90
No related branches found
No related tags found
No related merge requests found
......@@ -32,11 +32,15 @@ STATE_LABEL = {
# Default exit code
EXIT_CODE = STATE_OK
py_env = os.environ.copy()
py_env['JAVA_HOME'] = '/usr/lib/jvm/java-8-oracle'
py_env['HADOOP_HOME'] = '/usr/lib/hadoop'
def hadoop_query_df():
try:
data = {}
hadoop = subprocess.Popen(["hadoop", "fs", "-df"], stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
hadoop = subprocess.Popen(["hadoop", "fs", "-df"], stdout=subprocess.PIPE, stderr=subprocess.STDOUT, env=py_env)
# Format the output data from CSV to an array of dicts for ease-of-use
hadoopStd = str(hadoop.stdout.read(), 'UTF8')
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment