Hadoop调用了错误的API



我正在使用org.apache.hadoop.mapreduce API在Hadoop 2.3.0中执行一个简单的mapreduce功能,但是当我尝试运行它时,我收到以下错误

org.apache.hadoop.mapreduce.lib.input.FileSplit cannot be cast to org.apache.hadoop.mapred.InputSplit. 

因为我在我正在使用的mapreduce函数中调用的是这个

import org.apache.hadoop.fs.Path;
import org.apache.hadoop.conf.*;
import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.*;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;

我不知道为什么它继续使用旧的API,我修改了一些配置文件吗?

尝试使用hadoop dfsadmin -refreshNodes命令来引用节点。以便它将获取新的 API。

相关内容

  • 没有找到相关文章

最新更新