如何解决错误:java.lang.UnsatisfiedLinkError:org.apache.hadoop.io.nativeio.NativeIO$Windows
我是 Java 和 hadoop 的新手。我正在关注本教程 (https://developpaper.com/simple-java-hadoop-mapreduce-program-calculate-average-score-from-package-to-submit-and-run/)。我在提供输入时做了一些小的修改。请参考代码。
public class Score {
public static class Map extends Mapper<LongWritable,Text,IntWritable> {
// Implement map function
public void map(LongWritable key,Text value,Context context) throws IOException,InterruptedException {
// Convert the data of the input plain text file to string
String line = value.toString();
// Split the input data into rows first
StringTokenizer tokenizerArticle = new StringTokenizer(line,"\n");
// Process each line separately
while (tokenizerArticle.hasMoreElements()) {
// Line by space
StringTokenizer tokenizerLine = new StringTokenizer(tokenizerArticle.nextToken());
String strName = tokenizerLine.nextToken(); // student name
// section
String strScore = tokenizerLine.nextToken(); // grade section
Text name = new Text(strName);
int scoreInt = Integer.parseInt(strScore);
// Output name and score
context.write(name,new IntWritable(scoreInt));
}
}
}
public static class Reduce extends Reducer<Text,IntWritable,IntWritable> {
// Implement reduce function
public void reduce(Text key,Iterable<IntWritable> values,Context context)
throws IOException,InterruptedException {
int sum = 0;
int count = 0;
Iterator<IntWritable> iterator = values.iterator();
while (iterator.hasNext()) {
sum += iterator.next().get(); // calculate the total score
count++; // count the total number of accounts
}
Integer average = (int) sum / count; // calculate the average score
context.write(key,new IntWritable(average));
}
}
public static void main(String[] args) throws IOException,ClassNotFoundException,InterruptedException {
// TODO Auto-generated method stub
Configuration conf = new Configuration();
// " localhost:9000 "It needs to be set according to the actual
// situation
conf.set("mapred.job.tracker","localhost:9000");
// Input directory and output directory in an HDFS file system
String[] ioArgs = new String[] { "score.txt","output" };
String[] otherArgs = new GenericOptionsParser(conf,ioArgs).getRemainingArgs();
if (otherArgs.length != 2) {
System.err.println("Usage: Score Average <in> <out>");
System.exit(2);
}
Job job = new Job(conf,"Score Average");
job.setJarByClass(Score.class);
// Set map,combine and reduce processing classes
job.setMapperClass(Map.class);
job.setCombinerClass(Reduce.class);
job.setReducerClass(Reduce.class);
// Set output type
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(IntWritable.class);
// The input data set is divided into small data blocks splites to
// provide a RecordReder implementation
job.setInputFormatClass(TextInputFormat.class);
// Provide an implementation of recordwriter,responsible for data
// output
job.setOutputFormatClass(TextOutputFormat.class);
// Set input and output directories
FileInputFormat.addInputPath(job,new Path(otherArgs[0]));
FileOutputFormat.setOutputPath(job,new Path(otherArgs[1]));
System.exit(job.waitForCompletion(true) ? 0 : 1);
}
}
在那里我使用 maven 在 eclips 中尝试了程序源代码。我为 pom.xml 文件添加了依赖项,如下所示。
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>mapreducedemocode</groupId>
<artifactId>mapreducedemocode</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>mapreducedemocode</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-client</artifactId>
<version>2.7.3</version>
</dependency>
</dependencies>
</project>
但是当我运行代码时,它给出了以下异常。
Exception in thread "main" java.lang.UnsatisfiedLinkError: org.apache.hadoop.io.nativeio.NativeIO$Windows.access0(Ljava/lang/String;I)Z
at org.apache.hadoop.io.nativeio.NativeIO$Windows.access0(Native Method)
谁能帮我解决这个问题。请注意,我将输入文件 ('score.txt) 添加到项目中,并通过将参数添加为 'score.txt output' 来设置运行配置。提供参数是否有问题。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。