Merge pull request #3 from sorenmacbeth/master

I added reading of HADOOP_CONF_DIR environment variable
metamx · Aug 2, 2011 · 5c4b6ae · 5c4b6ae
2 parents 841d4e0 + 800d2e5
commit 5c4b6ae
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/azkaban/src/java/azkaban/app/AzkabanApplication.java b/azkaban/src/java/azkaban/app/AzkabanApplication.java
@@ -288,13 +288,19 @@ private ClassLoader getBaseClassloader() throws MalformedURLException
         final ClassLoader retVal;
 
         String hadoopHome = System.getenv("HADOOP_HOME");
-        if(hadoopHome == null) {
-            logger.info("HADOOP_HOME not set, using default hadoop config.");
-            retVal = getClass().getClassLoader();
-        } else {
+	String hadoopConfDir = System.getenv("HADOOP_CONF_DIR");
+
+        if(hadoopConfDir != null) {
+	  logger.info("Using hadoop config found in " + hadoopConfDir);
+	  retVal = new URLClassLoader(new URL[] { new File(hadoopConfDir).toURI().toURL() },
+				      getClass().getClassLoader());
+	} else if(hadoopHome != null) {
             logger.info("Using hadoop config found in " + hadoopHome);
             retVal = new URLClassLoader(new URL[] { new File(hadoopHome, "conf").toURI().toURL() },
                                         getClass().getClassLoader());
+        } else {
+            logger.info("HADOOP_HOME not set, using default hadoop config.");
+            retVal = getClass().getClassLoader();
         }
 
         return retVal;