Index: src/java/org/apache/hcatalog/common/HCatConstants.java =================================================================== --- src/java/org/apache/hcatalog/common/HCatConstants.java (revision 1156682) +++ src/java/org/apache/hcatalog/common/HCatConstants.java (working copy) @@ -87,4 +87,11 @@ public static final String HCAT_DROP_TABLE_EVENT = "HCAT_DROP_TABLE"; public static final String HCAT_ADD_DATABASE_EVENT = "HCAT_ADD_DATABASE"; public static final String HCAT_DROP_DATABASE_EVENT = "HCAT_DROP_DATABASE"; + + // System environment variables + public static final String SYSENV_HADOOP_TOKEN_FILE_LOCATION = "HADOOP_TOKEN_FILE_LOCATION"; + + // Hadoop Conf Var Names + public static final String CONF_MAPREDUCE_JOB_CREDENTIALS_BINARY = "mapreduce.job.credentials.binary"; + } Index: src/java/org/apache/hcatalog/har/HarOutputCommitterPostProcessor.java =================================================================== --- src/java/org/apache/hcatalog/har/HarOutputCommitterPostProcessor.java (revision 1156690) +++ src/java/org/apache/hcatalog/har/HarOutputCommitterPostProcessor.java (working copy) @@ -31,6 +31,7 @@ import org.apache.hadoop.mapreduce.JobContext; import org.apache.hadoop.tools.HadoopArchives; import org.apache.hadoop.util.ToolRunner; +import org.apache.hcatalog.common.HCatConstants; import org.apache.hcatalog.common.HCatException; import org.apache.hcatalog.common.HCatUtil; @@ -100,9 +101,9 @@ Configuration newConf = new Configuration(); FileSystem fs = archivePath.getFileSystem(newConf); - String hadoopTokenFileLocationEnvSetting = System.getenv("HADOOP_TOKEN_FILE_LOCATION"); + String hadoopTokenFileLocationEnvSetting = System.getenv(HCatConstants.SYSENV_HADOOP_TOKEN_FILE_LOCATION); if ((hadoopTokenFileLocationEnvSetting != null) && (!hadoopTokenFileLocationEnvSetting.isEmpty())){ - newConf.set("mapreduce.job.credentials.binary", hadoopTokenFileLocationEnvSetting); + newConf.set(HCatConstants.CONF_MAPREDUCE_JOB_CREDENTIALS_BINARY, hadoopTokenFileLocationEnvSetting); // LOG.info("System.getenv(\"HADOOP_TOKEN_FILE_LOCATION\") =["+ System.getenv("HADOOP_TOKEN_FILE_LOCATION")+"]"); } // for (FileStatus ds : fs.globStatus(new Path(dir, "*"))){