分享

【已解决】关于文件远程上传hdfs的问题

seraph50 发表于 2015-3-8 20:49:10 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 21 116085
seraph50 发表于 2015-3-10 19:47:07
提示: 作者被禁止或删除 内容自动屏蔽
回复

使用道具 举报

nextuser 发表于 2015-3-11 01:05:19

楼主,能否写出经历,借鉴下,相互帮助下
回复

使用道具 举报

flysky0802 发表于 2015-3-11 09:46:47
楼主,怎么解决的可否分享一下呢??
回复

使用道具 举报

seraph50 发表于 2015-3-11 11:19:06
提示: 作者被禁止或删除 内容自动屏蔽
回复

使用道具 举报

nextuser 发表于 2015-3-11 11:45:57
seraph50 发表于 2015-3-11 11:19
Hadoop在HA模式下远程上传文件的实现


如下文红字部分,直接这样就可以了吧
public class CopyToHDFS {
    public static void main(String[] args) throws IOException {

        Configuration conf = new Configuration();
       conf.set("fs.defaultFS", "hdfs://mycluster");

        FileSystem fs = FileSystem.get(conf);

        fs.copyFromLocalFile(new Path("/home/lance/log.txt"), new Path("/log"));
    }
}

回复

使用道具 举报

seraph50 发表于 2015-3-11 12:51:23
提示: 作者被禁止或删除 内容自动屏蔽
回复

使用道具 举报

nextuser 发表于 2015-3-11 12:59:14
第一步:
public class CopyToHDFS {
    public static void main(String[] args) throws IOException {

        Configuration conf = new Configuration();
       conf.set("fs.defaultFS", "hdfs://mycluster");

        FileSystem fs = FileSystem.get(conf);

        fs.copyFromLocalFile(new Path("/home/lance/log.txt"), new Path("/log"));
    }
}

第二步:
把下面文件复制到一种是直接把hadoop的配置文件放到工程目录下或则在代码里,设置下面属性
core-site.xml
  1. <configuration>
  2.     <property>
  3.         <name>fs.defaultFS</name>
  4.         <value>hdfs://mycluster</value>
  5.     </property>
  6. </configuration>
复制代码


hdfs-site.xml
  1. <configuration>
  2.     <property>
  3.         <name>dfs.nameservices</name>
  4.         <value>mycluster</value>
  5.     </property>
  6.     <property>
  7.         <name>dfs.ha.namenodes.mycluster</name>
  8.         <value>nn1, nn2</value>
  9.     </property>
  10.     <property>
  11.         <name>dfs.namenode.rpc-address.mycluster.nn1</name>
  12.         <value>192.168.11.2:9000</value>
  13.     </property>
  14.     <property>
  15.         <name>dfs.namenode.rpc-address.mycluster.nn2</name>
  16.         <value>192.168.11.7:9000</value>
  17.     </property>
  18.     <property>
  19.         <name>dfs.client.failover.proxy.provider.mycluster</name>
  20.         <value>org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider</value>
  21.     </property>
  22. </configuration>
复制代码







回复

使用道具 举报

seraph50 发表于 2015-3-11 13:28:27
提示: 作者被禁止或删除 内容自动屏蔽
回复

使用道具 举报

nextuser 发表于 2015-3-11 21:30:33
seraph50 发表于 2015-3-11 13:28
加载了配置文件,可以把红字的删了。配置文件里的属性值请按你自己集群的实际情况改

楼主通过命令行上传过文件吗?这个跟一个namenode是否也有区别。
回复

使用道具 举报

About_haoran 发表于 2015-3-17 11:03:49
eclipse在win7系统上怎么远程hadoop伪分布式集群开发呀
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条