草庐IT

hdfs_rtp

全部标签

hadoop - 水槽和远程 hdfs 接收器出错

我正在尝试使用hdfs接收器运行水槽。hdfs在不同的机器上正常运行,我什至可以与flume机器上的hdfs交互,但是当我运行flume并向它发送事件时,我收到以下错误:2013-05-2614:22:11,399(SinkRunner-PollingRunner-DefaultSinkProcessor)[WARN-org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:456)]HDFSIOerrorjava.io.IOException:Callabletimedoutafter25000msator

hadoop - 如何使用与客户端进程不同的所有者创建 HDFS 文件

HDFSAdministratorGuide州"Whenafileordirectoryiscreated,itsowneristheuseridentityoftheclientprocess,anditsgroupisthegroupoftheparentdirectory(theBSDrule)."此规则有任何异常(exception)吗?以用户“clientA”身份运行进程是否有任何方法可以创建具有不同所有者的文件?我正在使用hadoop.security.authentication=simple运行。看来我可以调用setOwner事后,这是一个完全有效的后备解决方案。

hadoop - 从 HDFS 集群下载文件

我正在开发一个将hdfs用作分布式文件存储的API。我制作了一个RESTapi,允许服务器使用Webhdfsmkdir、ls、创建和删除HDFS集群中的文件。但是由于Webhdfs不支持下载文件,是否有任何解决方案可以实现这一点。我的意思是我有一台运行我的RESTapi并与集群通信的服务器。我知道OPEN操作只支持读取文本文件内容,但假设我有一个大小为300MB的文件,我如何从hdfs集群下载它。你们有任何可能的解决方案吗?我想直接ping一个文件的数据节点,但这个解决方案是有缺陷的,因为如果文件大小为300MB,它会给我的代理服务器带来巨大的负载,所以有没有流式API来实现这个。

hadoop - 如何从 HDFS 执行 map reduce 程序(例如 wordcount)并查看输出?

我是Hadoop新手。我在eclipse中有一个简单的wordcount程序,它接受输入文件然后显示输出。但我需要从HDFS执行相同的程序。我已经为wordcount程序创建了一个JAR文件。任何人都可以让我知道如何进行吗? 最佳答案 您需要设置集群,即使是单节点集群。然后您可以从hadoop命令行运行您的.jar:jarRunsajarfile.UserscanbundletheirMapReducecodeinajarfileandexecuteitusingthiscommand.Usage:hadoopjar[mainCla

HADOOP HDFS不平衡问题

我有一个有8台机器的Hadoop集群,这8台机器都是数据节点。有一个程序运行在一台机器(比如机器A)上,它会在HDFS中连续创建序列文件(每个文件大约1GB)。问题来了:所有8台机器都具有相同的硬件和相同的容量。当其他机器的磁盘上还有大约50%的可用空间用于HDFS时,机器A只剩下5%。我查看了区block信息,发现几乎每个区block在机器A上都有一个副本。有什么方法可以平衡副本吗?谢谢。 最佳答案 这是默认的放置策略。它适用于典型的M/R模式,其中每个HDFS节点也是一个计算节点,写入器机器是均匀分布的。不喜欢的话还有HDFS-

sql - 是否有任何抽象层可用于 GFS 或 HDFS?

关闭。这个问题不符合StackOverflowguidelines.它目前不接受答案。这个问题似乎与helpcenter中定义的范围内的编程无关。.关闭9年前。Improvethisquestionfacebook使用的SQL和NOSQL数据库1.是使用GFS还是HDFS还是BOTH还是其他?2.可用于HDFS和GFS的不同抽象应用层有哪些??3.我听说过HADOOP,MapReduce是如何工作的?请说说优点。并对第二个问题也进行了深入的叙述。

hadoop - [hdfs]如何为每个datanode配置不同的dfs.datanode.data.dir?

我使用ambari来设置hadoop集群。但是当我配置hdfs的配置时。我发现如果我修改dfs.datanode.data.dir,configure会在所有datanodes上生效...如何为每个数据节点配置不同的配置?比如机器A有两block磁盘,分别挂载到/data1、/data2但是机器B只有一个盘,挂载到/data1所以我想将机器A的dfs.datanode.data.dir配置为“/data1,/data2”。但只有机器B的“/data1” 最佳答案 不存在的HDFS目录将被忽略。都放进去,没关系。

python - 通过 Python 处理 HDFS 中的多个文件

我在HDFS中有一个目录,其中包含大约10,000个.xml文件。我有一个python脚本“processxml.py”,它获取一个文件并对其进行一些处理。是否可以在hdfs目录中的所有文件上运行脚本,或者我是否需要先将它们复制到本地才能这样做?例如,当我在本地目录中的文件上运行脚本时,我有:cd/path/to/filesforfilein*.xmldopython/path/processxml.py$file>/path2/$filedone所以基本上,我将如何做同样的事情,但这次文件在hdfs中? 最佳答案 你基本上有两个选

hadoop - 如何使用 pig 从 hdfs 加载推特数据?

我只是使用flume流式传输一些推特数据并将其集群到HDFS现在我尝试将它加载到pig中进行分析。由于默认的JsonLoader函数无法加载数据所以我在谷歌中搜索一些可以加载这种类型的库数据。我找到了这个link并按照那里的说明进行操作。这是结果REGISTER'/home/hduser/Downloads/json-simple-1.1.1.jar';2016-02-2220:54:46,539[main]INFOorg.apache.hadoop.conf.Configuration.deprecation-fs.default.nameisdeprecated.Instead,u

hadoop - Hive CLI 如何从 HDFS 中检索巨大的结果文件?

在我通过CLI执行配置单元查询后,如下所示:$hive-eQUERY>output.txtHive客户端将编译QUERY并将其发送到Hadoop集群。Hadoop执行一些作业并将结果输出到文件(假设仅1个reducer)在HDFS。然后Hive客户端将检索这个单个文件,提取它,并输出到本地STDOUT。流程如下图所示:==============HadoopCluster==============|||||2.outputRESULTasasingle.gzfileatHDFSbecauseof1reducer||||1.QUERY||||3.HiveretrievestheRESU