如何用外部jar运行hadoop？

db2dz4w8 于 2021-06-01 发布在 Hadoop

关注(0)|答案(1)|浏览(376)

我将在hadoop2.9.0上运行map reduce项目。我在我的项目中使用xml rpc包，如下所示：

import org.apache.xmlrpc.*;

我将其他jar放入lib文件夹，当我在hadoop中运行我的项目jar时，它显示以下错误：
错误：java.lang.classnotfoundexception:org.apache.xmlrpc.xmlrpcclient
我执行了这个命令：

bin/hadoop jar MRV.jar SumMR /user/hadoop/input /user/hadoop/output -libjars lib/xmlrpc-2.0.1.jar: lib/commons-codec-1.10.jar

如何执行此命令而不出错 ClassNotFoundException ?

Java hadoop Jar

来源：https://stackoverflow.com/questions/53126365/how-to-run-hadoop-with-external-jar

1条答案

按热度按时间

bnlyeluc1#

私有静态void addjartodistributedcache（class classtoadd，configuration conf）引发ioexception{

// Retrieve jar file for class2Add
String jar = classToAdd.getProtectionDomain().
        getCodeSource().getLocation().
        getPath();
File jarFile = new File(jar);

// Declare new HDFS location
Path hdfsJar = new Path("/user/hadoopi/lib/"
        + jarFile.getName());

// Mount HDFS
FileSystem hdfs = FileSystem.get(conf);

// Copy (override) jar file to HDFS
hdfs.copyFromLocalFile(false, true,
    new Path(jar), hdfsJar);

// Add jar to distributed classPath
DistributedCache.addFileToClassPath(hdfsJar, conf);

}

赞(0）回复(0）举报 2021-06-02

我来回答

如何用外部jar运行hadoop？

1条答案

相关问题

热门标签

最新问答