你的主機名是localhost找host文件的時候，轉為在你的運行電腦上，也就是本機，并不是虛擬機，所以就沒有那個文件，建議修改虛擬機主機名，或者修改hosts文件。

沒有，它變成了另外一個錯誤，你要在編譯器中連接虛擬機，還要添加相關的矩陣文件

好像不是這個原因

我也有這個問題，我在想是不是虛擬機連接問題

package step1;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.FileSystem;

import org.apache.hadoop.fs.Path;

import org.apache.hadoop.io.Text;

import org.apache.hadoop.mapreduce.Job;

import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;

import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;

public class MR1 {

? ? //輸入文件相對路徑

private static String inPath = "/matrix/step1_input/matrix_2.txt";

//輸出文件的相對路徑

private static String outPath = "/matrix/step1_output";

//hdfs的地址

private static String hdfs = "hdfs://localhost:9000";

public int run() {

try {

//創建job配置類

Configuration conf = new Configuration();

//設置hdfs的地址

conf.set("cf.defaultFS", hdfs);

//創建一個job實例

Job job = Job.getInstance(conf,"step1");

//設置job 的主類

job.setJarByClass(MR1.class);

//設置job 的mapper類及reducer類

job.setMapperClass(Mapper1.class);

job.setReducerClass(Reducer1.class);

//設置mapper輸出的類型

job.setMapOutputKeyClass(Text.class);

job.setMapOutputValueClass(Text.class);

//設置reducer輸出類型

job.setOutputKeyClass(Text.class);

job.setOutputValueClass(Text.class);

FileSystem fs =FileSystem.get(conf);

//設置輸入和輸出路徑

Path inputPath = new Path(inPath);

if(fs.exists(inputPath)) {

FileInputFormat.addInputPath(job, inputPath);

}

Path outputPath = new Path(outPath);

fs.delete(outputPath,true);

?

FileOutputFormat.setOutputPath(job, outputPath);

return job.waitForCompletion(true)?1:-1;

} catch (IOException | ClassNotFoundException | InterruptedException e) {

e.printStackTrace();

}

return -1;

}

public static void main(String[] args) {

int result = -1;

result =new MR1().run();

if(result == 1) {

System.out.println("step1運行成功~~~");

}else if(result == -1) {

System.out.println("step1運行失敗~~~");

}

}

}

貼上源碼