我正在尝试将一个json文件读入hadoop mapreduce算法。我该怎么做？我已经将文件“testinput.json”放入hdfs内存的/input中。
调用mapreduce时我执行 hadoop jar popularityMR2.jar populariy input output ，输入说明dhfs内存中的输入目录。

public static class PopularityMapper extends Mapper<Object, Text, Text, Text>{

    protected void map(Object key, Text value,
                       Context context)
            throws IOException, InterruptedException {

        JSONParser jsonParser = new JSONParser();
        try {
            JSONObject jsonobject = (JSONObject) jsonParser.parse(new FileReader("hdfs://input/testinput.json"));
            JSONArray jsonArray = (JSONArray) jsonobject.get("votes");

            Iterator<JSONObject> iterator = jsonArray.iterator();
            while(iterator.hasNext()) {
                JSONObject obj = iterator.next();
                String song_id_rave_id = (String) obj.get("song_ID") + "," + (String) obj.get("rave_ID")+ ",";
                String preference = (String) obj.get("preference");
                System.out.println(song_id_rave_id + "||" + preference);
                context.write(new Text(song_id_rave_id), new Text(preference));
            }
        }catch(ParseException e) {
            e.printStackTrace();
        }
    }

}

我的Map器函数现在看起来像这样。我从dhfs内存中读取了文件。但它总是返回一个错误，文件找不到。
有人知道如何将这个json读入jsonobject吗？
谢谢