Hadoop任務執行過程中，在每一個map節點或者reduce節點能獲取一下環境變數，利用這些變數可以為特殊的需求服務，例如：獲取當前map節點處理的資料檔案的路徑。

hadoop是java實現的，利用java可以很方便的獲取相關環境變數，其內部包含在Context和MRJobConfig中（hadoop版本不一樣，可能會有區別，我的hadoop是0.21）。

舉例：

import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.MRJobConfig;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.lib.input.FileSplit;


public class MergeDaysMapper extends Mapper<LongWritable, Text, Text, Text> {

private String inputFile = null;

public void setup(Context context)
{
System.err.println("[STARTS TO GET PARAMETERS OF THIS JOB]");
Path input = ((FileSplit)context.getInputSplit()).getPath();
inputFile = input.toString();
System.err.println("Input: "+ input.toString());
System.out.println("Input: "+ input.getName());
System.out.println("MAP_INPUT_FILE: " + MRJobConfig.MAP_INPUT_FILE);
System.out.println("MAP_INPUT_PATH:"+ MRJobConfig.MAP_INPUT_PATH);
System.out.println("MAP_INPUT_START:"+ MRJobConfig.MAP_INPUT_START);
System.err.println("JOB_NAME" + MRJobConfig.JOB_NAME);
System.out.println("[FINISHED GETTING PARAMETERS OF THIS JOB]");
}
    
public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException
{
if (null == inputFile)
   context.write(new Text("key"), new Text("inputFile"));
else
context.write(new Text("key"), new Text(inputFile));
}
}

同時，在streaming任務中也有同樣的需求，需要獲取相關環境變數，查過別人的資料，如下：

{{

streaming框架通過設定環境變數的方式給mapper、reducer程式傳遞配置資訊。常用的環境變數如下：

}}

自己測試了一下，不對，又是版本問題，查了http://hadoop.apache.org/mapreduce/docs/r0.21.0/streaming.html#How+do+I+get+the+JobConf+variables+in+a+streaming+job%27s+mapper%2Freducer%3F

解決如下：

例子：

#!/bin/sh


while read line
do
  echo "$line"
  echo $mapreduce_map_input_file
done

測試通過