FileSystem.getConfig(config)
投掷 org.apache.hadoop.ipc.RPC.getProxy exception
在尝试创建hdfs目录时。
config.addResource(new Path(String.format("%s/core-site.xml",TestProperties.HDFS_CONF_DIR)));
config.addResource(new Path(String.format("%s/hdfs-site.xml",TestProperties.HDFS_CONF_DIR)));
config.set("fs.hdfs.impl", org.apache.hadoop.hdfs.DistributedFileSystem.class.getName());
config.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName());
FileSystem dfs = FileSystem.get(config);
附加完整的堆栈跟踪:
java.lang.nosuchmethoderror:org.apache.hadoop.ipc.rpc.getproxy(ljava/lang/class;jljava/net/inetsocketaddress;lorg/apache/hadoop/security/usergroupinformation;lorg/apache/hadoop/conf/configuration;ljavax/net/socketfactory;ilorg/apache/hadoop/io/retry/retrypolicy;z) lorg/apache/hadoop/ipc/versionedprotocol;在org.apache.hadoop.hdfs.dfsclient.createrpcnamenode(dfsclient。java:135)在org.apache.hadoop.hdfs.dfsclient。java:280)在org.apache.hadoop.hdfs.dfsclient。java:245)位于org.apache.hadoop.hdfs.distributedfilesystem.initialize(distributedfilesystem)。java:100)在org.apache.hadoop.fs.filesystem.createfilesystem(文件系统)。java:2761)在org.apache.hadoop.fs.filesystem.access$200(文件系统)。java:99)在org.apache.hadoop.fs.filesystem$cache.getinternal(filesystem。java:2795)在org.apache.hadoop.fs.filesystem$cache.get(filesystem。java:2777)在org.apache.hadoop.fs.filesystem.get(filesystem。java:386)在org.apache.hadoop.fs.filesystem.get(文件系统)。java:179)在org.apache.atlas.regression.util.hdfsutil.createdirectory(hdfsutil。java:46)在org.apache.atlas.regression.tests.falconintegrationtest.setup(falconintegrationtest。java:43)
集群中的hadoop版本是2.7.3,pom.xml版本是2.7.3。有什么问题吗?
暂无答案!
目前还没有任何答案,快来回答吧!