草庐IT

mapreduce-name

全部标签

hadoop - 使用pywebhdfs创建hdfs文件报错: [Errno -2] Name or service not known

关于我的开发环境的一些信息:开放堆栈:朱诺hadoop:2.4.1pywebhdfs:0.4.0我通过openstacksahara客户端API创建一个hadoop集群,然后我想使用pywebhdfs创建一个文件到HDFS(用于在创建的hadoop集群上启Action业)。但是在创建HDFS文件时出现错误,错误信息为:HTTPConnectionPool(host='vanillacluster-vanillacluster-slave-vanilla-002.novalocal',port=50075):Maxretriesexceededwithurl:/webhdfs/v1/us

scala - Spark 斯卡拉 : JniBasedUnixGroupsMapping: Error getting groups for XXX: The user name could not be found

我一直在使用scalaIDE中的spark从我的本地系统连接到Hive(在集群中),最后将我的hive-site.xml正确地放置在Spark/conf文件夹和类路径中并且能够连接到Metastore但是无法访问配置单元表。如何更改HiveContext的用户15/12/2210:28:42INFOParseDriver:解析命令:显示表15/12/2210:28:43信息ParseDriver:解析已完成15/12/2210:28:45信息Metastore:尝试使用URIthrift://Server.com:9083连接到Metastore22年12月15日10:28:46信息J

Hadoop Map Reduce 作业 : Class org. 找不到 apache.hive.hcatalog.mapreduce.HCatInputFormat

我正在使用kylin.它是一个数据仓库工具,它使用hadoop、hive和hbase。它附带示例数据,以便我们可以测试系统。我正在构建这个样本。这是一个多步骤过程,其中许多步骤都是map-reduce作业。第二步是ExtractFactTableDistinctColumns,这是一个MR作业。如果没有在hadoop日志中写入任何内容,这项工作就会失败。深入挖掘后,我在logs/userlogs/application_1450941430146_0002/container_1450941430146_0002_01_000004/syslog中发现了一个异常2015-12-2407

java - 在非集群计算机上编译Hadoop MapReduce并在Hadoop集群上运行

我已经阅读了很多关于Hadoop的文档和信息,但无法弄清楚如何实现这个简单的工作流:我想在我的工作机器上使用HadoopJavaAPI开发和编译HadoopMapReduce,并安装了所有IDE等。我想以最简单的方式(最好是通过IDE)在Hadoop集群上部署和运行MapReduce作业我希望能够将这些MapReduce作业集成到外部应用程序中,并能够透明地运行它们。看起来所有开发/编译/运行都应该在MasterNode上完成,其中存在bin/hadoop命令行实用程序和Hadoop库。我说得对吗?开发、运行、部署MapReduce应用程序的一般方法是什么?是否有某种maven插件可以

hadoop - Name Node 同时作为 Secondary Name Node 是否理想?

我正在通过RaspberryPi练习hadoop集群,根据本教程(http://www.widriksson.com/raspberry-pi-hadoop-cluster/),他在hadoopmasters文件配置中设置了node1,这令人困惑,因为他还使用节点启动hadoop守护进程。我也想知道他配置的原因附言-只需ctrl+f大师 最佳答案 不,这并不理想。如何配置集群取决于您。在本教程中,作者决定同时使用node1作为P-NN和S-NN。请记住,RPiHadoop集群仅适用于开发和测试,而不适用于生产环境。在单独的机器上运行

hadoop - MapReduce History Server 在哪里存储它的数据?

基于文档:MapReduceHistoryServerAPI,我可以使用不同的REST调用获取所有信息。有谁知道历史服务器最初存储/读取数据的位置?还有那是什么格式? 最佳答案 它将数据存储在HDFS中。在Cloudera和Hortonworks发行版中,它将位于/user/history/done下并由mapred拥有。我们还可以使用参数mapreduce.jobhistory.done-dir和mapreduce.jobhistory.intermediate-done-dir提供自定义位置。

Hadoop MapReduce 负载均衡

假设一个hadoop集群有3个slave节点和1个master节点,复制因子为2。进一步假设一个文件F被拆分为A、B、C3个block,分别存储如下:从机1:A、B从机2:A、C从机3:B、C此外,假设您启动了一个mapreduce作业来计算F中的单词数,并且每个block被拆分3次。我的问题是映射器是如何分布的,以便优化它们以获得最大的生产力?一种可能性:从站1:3个映射器在A上工作从属2:3个映射器用于C从机3:3个映射器在B上工作但是hadoop如何避免以下情况呢?从机1:6个映射器(A上3个,B上3个)从机2:空闲从机3:C上的3个映射器 最佳答案

hadoop - 使用 mapreduce 修改 hdfs 上的文件

我可以修改驻留在hdfs上的文件吗?是创建具有修改内容的临时文件并删除原始文件的唯一方法吗?我可以使用map-reduce修改文件吗?是否可以并行修改不同的文件block并以某种方式合并到一个文件中? 最佳答案 一旦文件在HDFS中,您就不能修改它,除非附加到它。看到这个确认追加是可能的答案:AppenddatatoexistingfileinHDFSJavaMapreduce允许您并行操作文件,每个映射器读取文件的一个block,同时运行多个映射器。这就是它设计的工作方式。任何给定的映射器都可以过滤行并很容易地将全部、部分或全部写

hadoop mapreduce编程if条件

我写了下面的代码,它没有比较ifblock,它继续进入elseblock。请仔细检查并检查是否发现任何差异。请帮帮忙publicclassReduceIncuranceextendsReducer{publicvoidreduce(Textkey,Iterablevalues,Contextcontext)throwsIOException,InterruptedException{intsum=0;intcount=0;String[]input=values.toString().split(",");for(Stringval:input){System.out.println(

java - 为什么 Oozie 在运行 MapReduce 作业时分配更多内存?

我正在使用oozie运行MapReduce作业。从工作流中我只是调用MapReduce驱动程序类,除此之外别无其他。但是对于这个oozie工作流程需要大量内存。它需要至少2GB的容器大小来调用驱动程序类。下面是workflow.xml${jobTracker}${nameNode}mapred.job.queue.name${jobQueue}${jobScript}${arguments}${queueName}${wf:id()}myPath/MyDriver.sh#MyDriver.shJobfailedfailed:[${wf:errorMessage(wf:lastError