草庐IT

amazon-web-services - 在亚马逊。我将结果整理到主节点上,然后准备写入 S3,出现以下错误 :

在Hadoop中,我将结果整理到主节点上,然后准备写入S3,出现以下错误:18/08/1920:10:13WARNDataStreamer:ExceptionforBP-2033025931-192.168.3.27-1534682170082:blk_1073741835_1011java.io.EOFException:UnexpectedEOFwhiletryingtoreadresponsefromserveratorg.apache.hadoop.hdfs.protocolPB.PBHelperClient.vintPrefixed(PBHelperClient.java:4

hadoop - 编写 Flume 配置,将不断增长的文件上传到 HDFS

我是Flume的新手,在配置方面遇到了一些问题。我在OracleVirtualBox上使用HortonworksSandboxHDP2.6.5(如果这很重要)。我的VM中有一个文本文件input_data.txt:input_data.txt的内容如下所示:我使用以下命令来创建并逐渐增加输入:catinput_data.txt|whilereadline;doecho"$line";sleep0.2;done>output.txt我想要实现的目标:1)编写一个Flume配置,将不断增长的output.txt文件上传到HDFS2)如果可能-HDFS中的目标文件必须在每次源文件(/usr/

hadoop - 该示例如何在 Oozie 最佳情况下找到库?

根据Oozie的文档,我尝试在Oozie上运行一个map-reduce的例子。众所周知,'workflow.xml'(和'coordinator.xml')应该在HDFS中。然后输入命令:ooziejob-ooziehttp://localhost:11000/oozie-configexamples/apps/map-reduce/job.properties-run。而且我也知道“job.properties”应该在本地文件系统中。但有两件事让我感到困惑:1.为什么workflow.xml中的jar或class变量来自HDFS的lib目录?2.oozie-examples-4.3.

hadoop - cp 命令在 Hadoop 中如何工作?

我正在阅读“Hadoop:权威指南”并解释我的问题让我引用书中的内容distcpisimplementedasaMapReducejobwheretheworkofcopyingisdonebythemapsthatruninparallelacrossthecluster.Therearenoreducers.Eachfileiscopiedbyasinglemap,anddistcptriestogiveeachmapapproximatelythesameamountofdatabybucketingfilesintoroughlyequalallocations.Bydefau

hadoop - 如何使用 BDM(Informatica) 将文件从本地文件系统复制到 hdfs 文件系统?

我正在使用Informatica版本10.2.1并使用BDM我想将文件从本地文件系统复制并粘贴到HDFS文件系统。我是BDM的新手,不知道该怎么做。目前我已经创建了一个对象并填充了Read和Write参数。我同时使用InputType和OutputType作为command并发出命令hdfsdfs-copyFromLocal-f/tmp/x。csv/tmp/x非常感谢任何帮助。编辑粘贴错误图片。 最佳答案 Informatica中的Command输入类型用于读取数据。像catfilename.txt流出数据以供Informatica

apache-spark - 在用压缩文件替换 HDFS 中的小文件时如何避免破坏事件的 Hive/Presto 查询?

我们有100多个HDFS分区,我们每天每小时都会写入这些分区。分区是每天进行的,以便直接加载到Hive中,数据以Parquet格式写入。我们遇到的问题是,因为我们想尽可能快地获取数据可查询,每小时写入导致很多小文件。有很多例子,例如Howtocombinesmallparquetfilestoonelargeparquetfile?对于合并代码;我的问题是在移动/替换新压缩的文件以替换小文件时如何避免破坏人们的主动查询? 最佳答案 Metastore对每个分区都有一个文件系统位置。该位置通常基于表和分区:hdfs://namenod

hadoop - Sqoop 停留在进度的 5%

我正在使用Sqoop将数据从Oracle导入到HDFS。当Job启动时,它会停留在5%的进度上大约1小时,并且输出以下信息:INFOmapreduce.Job:TaskId:attempt_1535519556038_0015_m_000037_0,Status:FAILEDContainerlaunchfailedforcontainer_1535519556038_0015_01_000043:org.apache.hadoop.yarn.exceptions.YarnException:Unauthorizedrequesttostartcontainer.Thistokenis

hadoop - 使用 ambari UI 在 HDP 集群中编辑 hdfs-default.xml

我有一个使用HortonworksDataPlatform2.6.1构建的HBase集群,我想编辑hdfs-default.xml中的一些属性。我们可以使用ambariUI编辑hdfs-default.xml吗?如果我们在所有节点中手动编辑文件,我们需要重新启动哪些服务? 最佳答案 是的,你可以,但Ambari不会编辑默认文件,它会编辑hdfs-site.xml,你至少需要重新启动每个HDFS客户端和服务才能进行更改产生影响。不要手动编辑磁盘上的文件-Ambari会在下次服务重启时覆盖它们

hadoop - 无法以非 sudo 用户身份写入 HDFS

我已经通过更改了hdfs目录的权限hdfsdfs-chmod777/path/to/dir但是,当以非sudo用户身份写入该目录时,出现权限错误Causedby:org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.AccessControlException):权限被拒绝:user=crtemois,access=WRITE,inode="/aggregation/system/data/clean":owners:hdfs:drwxr-xr-x 最佳答案

hadoop - 使用 API 在 Hadoop 中移动文件

是否可以使用FileSystem类在hadoop中移动文件https://hadoop.apache.org/docs/r2.7.1/api/index.html?org/apache/hadoop/fs/FileSystem.html或类似的? 最佳答案 是的,这是可能的。对于比hadoopfs-cp更快的MapReduce副本,查看DistCpsourcecode或者如果你真的想移动一个文件hadoopfs-mvsourcecode.注意:“移动”实际上是HDFS中的“重命名”。FileSystem#rename是你想要的。