草庐IT

HADOOP_PREFIX

全部标签

java - 在 Hadoop 2.2.0 中打开缓存文件

在使用job.addCacheFile()将缓存文件添加到作业并使用我的映射器使用context.getCacheFiles()将其拉下后。如何打开缓存文件。我试过使用:BufferedReaderreader=newBufferedReader(newFileReader(filename));(下面注释)其中文件名是URI的toString(),但我收到一个IOException,指出该文件不存在。谁能帮我吗?importjava.io.*;importjava.net.*;importjava.util.*;importjava.util.regex.*;importorg.ap

hadoop - bin/hadoop : line 133: C:Java/jdk1. 7.0_45/bin/java: 没有那个文件或目录

有人可以帮忙吗?我正在尝试获取hadoop2.2.0版本并收到错误消息$bin/hadoop版本bin/hadoop:第133行:C:Java/jdk1.7.0_45/bin/java:没有那个文件或目录bin/hadoop:line133:exec:C:Java/jdk1.7.0_45/bin/java:cannotexecute:Nosuchfileordirectory我正在尝试在Windows7/64上安装单实例hadoop。我确实在“c/+1/Hadoop/hadoop-2.2.0”上安装了Cygwin64和hadoopJAVA_HOME是$echo$JAVA_HOMEc:J

java - Hive Driver Connection 线上的 Hadoop 中的 ClassNotFoundException 引起的 NoClassDefFoundError?

通常我从谷歌搜索开始寻找解决方案,但这个错误似乎以前没有发生过。Exceptioninthread"main"java.lang.NoClassDefFoundError:org/apache/hadoop/util/Shellatorg.apache.hadoop.hive.conf.HiveConf$ConfVars.findHadoopBinary(HiveConf.java:906)atorg.apache.hadoop.hive.conf.HiveConf$ConfVars.(HiveConf.java:237)atorg.apache.hive.jdbc.HiveConne

Hadoop - Cloudera MRV1 集群规划 - 理想集群的最小节点数是多少,它看起来如何?

我手动安装了一个具有以下配置的三节点集群:Master/SlaveNode0-NameNode,SecondaryNameNode,JobTracker,HMaster,DataNode,TaskTracker,HRegionServer,HiveMetaStore,DatabaseforHive/Sqoop,HiveServer2,HCatalog,OozieServer,Zookeeper,Oozie-client,Hive-client,pig-client,M/Rclienttools,SqoopSlaveNode1-DataNode,TaskTracker,HRegionSe

Hadoop Reducer 执行重现

所以映射器只在包含给定数据block的给定从节点上执行一次,对吗?但是Reducer可能会执行多次,因为同一个键可能来自许多Mapper节点,对吗?此外,对于单个MapReduce作业,每个Mapper都会进行Shuffle和Sort是否正确? 最佳答案 一般来说,我认为说Mapper/Reducer被执行了多少次是不合适的,因为它们广泛分布在不同的节点中,由MRv1中的JobTracker或MRv2中的ResourceManager调度。但希望我下面的回答可以帮助您更好地理解。问:“所以映射器只在包含给定数据block的给定从节点

hadoop - Namenode如何决定在哪个datanode中写入一个 block

我只是想知道这个。假设我正在将一个80GB的文件复制到HDFS,并且我的block大小是64MB。现在在收集了一个block的数据后,名称节点将block写入数据节点。这是我的问题:名称节点以何种方式选择应将block写入哪个数据节点。是随机选择还是循环选择? 最佳答案 NameNode会根据负载分配因子选择datanode上的block。它将以平衡所有正在运行的数据节点上的负载的方式选择block。此外,NameNode不会收集一个block的数据并将其写入数据节点。当向NameNode发送写请求时,它会分配要写入各个数据节点的b

hadoop - pig - 复制连接

我有两个输入文件学生文件:abc304.5xyz349.5def286.5klm3510.5位置文件:abchawthornexyzartesiadefgarnetklmvanness我想要的输出abchawthornexyzartesiadefgarnetklmvanness为此,我编写了以下pig程序。A=LOAD'/user/hive/warehouse/students.txt'USINGPigStorage('')AS(NAME:CHARARRAY,AGE:INT,GPA:FLOAT);B=LOAD'/user/hive/warehouse/location.txt.txt'

java - Hadoop 的输入和输出如何工作?

我只是使用本教程在我的本地计算机上设置我的单节点Hadoop集群-http://ac31004.blogspot.com/2013/10/installing-hadoop-2-on-mac_29.html在本教程中,我遵循了以下说明:试试lshadoopfs-ls如果你得到ls:`.':没有那个文件或目录那么hadoop文件系统中就没有home目录了。所以hadoopfs-mkdir/userhadoopfs-mkdir/user/您登录计算机时使用的名称在哪里。现在切换到$HADOOP_INSTALL目录并上传文件hadoopfs-putLICENSE.txt当我使用以下命令时:h

hadoop - 在 Hadoop 文件系统中复制本地文件

以编程方式在HDFS中复制文件的最快方法是什么?我尝试了DistCp但无法获得合适的内容 最佳答案 distcp对于localfFS到HDFS和HDFS到HDFS复制来说工作得很好。然而,它并没有为我们提供MapReduce的高并行性的好处,因为输入数据驻留在localFS(非分布式存储)而不是HDFS上。因此,使用两者中的任何一个都会给你几乎相同的性能,这显然取决于输入数据的硬件和大小。顺便说一句,DistCpbutcouldn'tgettheappropriatecontent是什么意思?

hadoop - 分布式系统-主服务器故障

我最近在分布式系统上阅读了一些内容,例如Google的MapReduce和GSF研究论文。这两个系统都依赖于Master节点的存在,该节点协调其他“worker”节点。我想知道设计师如何保护自己免受主失效的影响?在MapReduce论文中,我们可以阅读:Itiseasytomakethemasterwriteperiodiccheckpointsofthemasterdatastructuresdescribedabove.Ifthemastertaskdies,anewcopycanbestartedfromthelastcheckpointedstate我不清楚世卫组织负责监测主故