hadoop远程文件创建失败

lnvxswe2 于 2021-06-03 发布在 Hadoop

关注(0)|答案(3)|浏览(256)

我正在尝试从集群外部在hdfs中创建一个文件（hdfs api），如下所示：

Configuration conf = new Configuration();
 conf.set("mapred.job.tracker", "192.168.56.101:54310"); 

 conf.set("fs.default.name", "hdfs://192.168.56.101:54311");

 FileSystem fs = FileSystem.get(conf);

 fs.createNewFile(new Path("/app/hadoop/tmp/data/tools.txt"));

获取错误：

Exception in thread "main" org.apache.hadoop.ipc.RemoteException: java.io.IOException: Unknown protocol to job tracker: org.apache.hadoop.hdfs.protocol.ClientProtocol
at org.apache.hadoop.mapred.JobTracker.getProtocolVersion(JobTracker.java:370)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:622)
at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:587)
at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1432)
at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1428)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:416)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190)
at org.apache.hadoop.ipc.Server$Handler.run(Server.java:1426)
at org.apache.hadoop.ipc.Client.call(Client.java:1113)
at org.apache.hadoop.ipc.RPC$Invoker.invoke(RPC.java:229)
at $Proxy1.getProtocolVersion(Unknown Source)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:85)
at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:62)
at $Proxy1.getProtocolVersion(Unknown Source)
at org.apache.hadoop.ipc.RPC.checkVersion(RPC.java:422)
at org.apache.hadoop.hdfs.DFSClient.createNamenode(DFSClient.java:183)
at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:281)
at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:245)
at org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:100)
at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:1446)
at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:67)
at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:1464)
at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:263)
at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:124)
at LineCounter.main(LineCounter.java:107)

hadoop hdfs

来源：https://stackoverflow.com/questions/22744660/hadoop-remote-file-creation-fails

3条答案

按热度按时间

flvlnr441#

我使用以下方法，它在linux vm上的单节点群集上运行：

Configuration conf = new Configuration();
        conf.set("fs.default.name", "hdfs://localhost:9000");

我建议您尝试使用9000作为端口号，否则请从hadoop配置文件“site core.xml”中找出需要使用的正确端口号。我的文件是这样的：

<?xml version="1.0"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
<configuration>
  <property>
    <name>fs.default.name</name>
    <value>hdfs://localhost:9000</value>
  </property>
  <property>
    <name>hadoop.tmp.dir</name>
    <value>~/hacking/hd-data/tmp</value>
  </property>
  <property>
    <name>fs.checkpoint.dir</name>
    <value>~/hacking/hd-data/snn</value>
  </property>
</configuration>

另外，正如sachinjose指出的，我也建议您从代码中删除以下内容：

conf.set("mapred.job.tracker", "192.168.56.101:54310");

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

n3ipq98p2#

namenode公开了两个端口一个是ipc端口（默认为8020）和webui（默认为50070）。对于从远程机器访问hdfs文件系统，无需设置属性 mapred.job.tracker 仅限 fs.default.name 就足够了，请确保您使用的是正确的依赖于hdfs的库版本，因为可以从远程计算机访问cluster和namenode。
在连接到远程hdfs之前，通过检查集群中anynodes或edgenode中的core-site.xml文件，找到fs.default.name的值（8020 default）。您可以通过在任何节点中执行以下命令来确保ipc端口是否正确

hadoop fs -ls hdfs://192.168.56.101:54310/

如果您能够访问hdfs，那么可以在conf.set方法中给出（hdsfuri上方）

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

gjmwrych3#

请检查name node和jobtracker deamons是否正在运行，以及您提到的端口是否正确。

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

我来回答

hadoop远程文件创建失败

3条答案

相关问题

热门标签

最新问答