Index: yarn/src/main/java/org/apache/hama/bsp/BSPTaskLauncher.java =================================================================== --- yarn/src/main/java/org/apache/hama/bsp/BSPTaskLauncher.java (revision 1663917) +++ yarn/src/main/java/org/apache/hama/bsp/BSPTaskLauncher.java (working copy) @@ -188,11 +188,12 @@ } classPathEnv.append(File.pathSeparator); - classPathEnv.append("./" + YARNBSPConstants.HAMA_SYMLINK + - "/" + YARNBSPConstants.HAMA_RELEASE_VERSION + "/*"); +// classPathEnv.append("./" + YARNBSPConstants.HAMA_SYMLINK + +// "/" + YARNBSPConstants.HAMA_RELEASE_VERSION + "/*"); + classPathEnv.append("./" + YARNBSPConstants.HAMA_SYMLINK); classPathEnv.append(File.pathSeparator); - classPathEnv.append("./" + YARNBSPConstants.HAMA_SYMLINK + - "/" + YARNBSPConstants.HAMA_RELEASE_VERSION + "/lib/*"); +// classPathEnv.append("./" + YARNBSPConstants.HAMA_SYMLINK + +// "/" + YARNBSPConstants.HAMA_RELEASE_VERSION + "/lib/*"); Vector vargs = new Vector(); vargs.add("${JAVA_HOME}/bin/java"); Index: yarn/src/main/java/org/apache/hama/bsp/YARNBSPConstants.java =================================================================== --- yarn/src/main/java/org/apache/hama/bsp/YARNBSPConstants.java (revision 1663917) +++ yarn/src/main/java/org/apache/hama/bsp/YARNBSPConstants.java (working copy) @@ -66,18 +66,19 @@ */ public static final String HAMA_SYMLINK = "hama"; + /** * Hama release file name */ - public static final String HAMA_RELEASE_FILE = "hama-0.6.4.tar.gz"; + //public static final String HAMA_RELEASE_FILE = "hama-0.6.4.tar.gz"; /** * Hama release version */ - public static final String HAMA_RELEASE_VERSION = "hama-0.6.4"; + //public static final String HAMA_RELEASE_VERSION = "hama-0.6.4"; /** * Hama release file source location */ - public static final String HAMA_SRC_PATH = "/home/hadoop"; + //public static final String HAMA_SRC_PATH = "/home/hadoop"; } Index: yarn/src/main/java/org/apache/hama/bsp/YARNBSPJobClient.java =================================================================== --- yarn/src/main/java/org/apache/hama/bsp/YARNBSPJobClient.java (revision 1663917) +++ yarn/src/main/java/org/apache/hama/bsp/YARNBSPJobClient.java (working copy) @@ -234,11 +234,12 @@ localResources.put(YARNBSPConstants.APP_MASTER_JAR_PATH, amJarRsrc); // Copy from hama-${version}.tar.gz to HDFS - Path hamaDstPath = new Path(getSystemDir(), YARNBSPConstants.HAMA_RELEASE_FILE); + String hamaRelase = System.getProperty("hama.release.file"); + Path hamaSrcPath = new Path(hamaRelase); + LOG.info("hama file name : " + hamaSrcPath.getName()); + Path hamaDstPath = new Path(getSystemDir(), hamaSrcPath.getName()); hamaDstPath = fs.makeQualified(hamaDstPath); - fs.copyFromLocalFile(false, true, - new Path(YARNBSPConstants.HAMA_SRC_PATH, YARNBSPConstants.HAMA_RELEASE_FILE), - hamaDstPath); + fs.copyFromLocalFile(false, true, hamaSrcPath, hamaDstPath); FileStatus hamaStatus = fs.getFileStatus(hamaDstPath); URL hamaReleaseUrl = ConverterUtils.getYarnUrlFromPath(hamaDstPath .makeQualified(fs.getUri(), fs.getWorkingDirectory()));