草庐IT

reducer-combiner

全部标签

java - Hadoop:测量每个阶段的持续时间(map、shuffle/sort、reduce)

有一个非常相似的问题我想知道。HowcanImeasurethedurationofeachphase(map,shuffle/sort,reduce)inHadoop?答案是tasktracker的web/ui显示应用程序的每个持续时间。但是我的环境是hadoop-2.2.0,没有tasktracker。所以tasktrackerweb/ui"localhost:50030/tasktracker.jsp"不工作。我猜答案只适用于较低版本的hadoop(1.x.x)。我如何测量hadoop-2.x.x版本中每个阶段(map、shuffle/sort、reduce)的持续时间?是否有任

ruby-on-rails - 使用 map-reduce 进行视频转换

我有一个RubyonRails应用程序,用户可以在其中上传视频,我正在寻找一个系统来将用户上传的视频转换为FLV格式。目前我们正在使用FFMPEG并且由于视频转换是一项繁重的任务,它似乎需要花费大量时间和大量CPU资源..我们正在研究是否可以使用map-reduce/Hadoop框架来实现视频转换,因为它是完全分布式的。使用map-reduce进行实时视频转换是不是一个好的选择?如果是这样,如何实现?注意:每个视频文件大小约为50-60MB。 最佳答案 您的要求是“实时”转换。请记住,Hadoop是一个“批处理框架”。恕我直言,我认

java - 运行 Hadoop Map Reduce 作业,错误 : Unsupported major. 次要版本 51.0

我正在使用hadoop2.2.0在AmazonWebServicesRedHat6.4上运行map-reduce作业。我正在使用的Jar文件是在我的本地Windows7计算机上构建的。mapreduce作业在我的Windows7机器上本地安装的Hadoop上运行良好,但是当我尝试在Amazon实例上运行它时,我收到以下错误:Exceptioninthread"main"java.lang.UnsupportedClassVersionError:mapReduce/TestXMLConfig:Unsupportedmajor.minorversion51.0atjava.lang.Cl

hadoop - 我们能否将我们的 HDFS 数据或 Map Reduce 输出显示为 HTML 表单或 JSP 页面?

是否可以将我们的HDFS数据或MapReduce输出显示为HTML表单或JSP页面?如果是,那么如何? 最佳答案 在web服务和J2EE项目的帮助下,使用Hadoop文件系统api(引用here)来cathdfs文件,您可以在网页中显示结果。但是,请记住您正在处理的数据大小,巨大的数据(TB和PB)也会影响您的网络应用内存。 关于hadoop-我们能否将我们的HDFS数据或MapReduce输出显示为HTML表单或JSP页面?,我们在StackOverflow上找到一个类似的问题:

java - 在 eclipse 中调试 map reduce 作业

我想使用eclipse调试Map-reduce作业(pig、hive)。也就是说,在hadoop源java文件中设置断点并在运行map-reduce作业时检查元素。为此,我使用eclipse启动了所有服务,并且可以调试一些类文件。但是我不能创建一个完整的调试环境。谁能告诉我怎么做? 最佳答案 我不知道有什么eclipse工具可以满足您的需求。如果您正在寻找可能的解决方案,以下将适用于java。importjava.util.logging.Logger;为了调试javamapreduce文件,您可以为每个类(驱动程序、映射器、red

hadoop - 如何执行一对多 map-reduce 连接?

当我们有:文件1personid1,name1personid2,name2文件2personid1,address2文件2personid2,address2我想要reducer输出personid1,name1,address2personid2,name2,address2 最佳答案 您似乎可以使用personid作为映射器的键。然后您将确保在一个reducer中获得属于一个personid的所有记录作为迭代器。现在您需要区分哪个记录来自哪个来源,因此最好将标识符放在值上。importorg.apache.hadoop.con

java - 当我在 Reducer 中读取它们时,Mapper 中发送的文本/字符串值是错误的

我正在Mapper中发送一些数据,当我尝试在Reducer中读取它们时,它们发生了一些变化。在简历中,我使用set函数填充数据,然后使用get函数在reducer中读取它们。我不明白为什么如果我执行println,数据会不同。我发送的数据在一个名为“ValorFechaHora”的类中,有3个变量Medicion、Fecha和Hora:publicclassValorFechaHoraimplementsWritable{ privateIntWritableMedicion; privateTextFecha; privateTextHora; publicvoidValorFec

hadoop - 设置 Pig 作业的最小 reducer 数量

我想为我的PigJob设置要启动的最小reducer数量。我尝试使用:SETdefault_parallel57;但是,这会强制所有作业都必须有57个reducer。是否有任何我可以设置的设置强制PigJob具有至少57个或更多的reducer。 最佳答案 我认为这是不可能的。您可以将default_parallel设置为57,对于那些您希望拥有更多reducer的操作,您可以使用PARALLEL指定更高的数量。我知道这并不是您想要的。 关于hadoop-设置Pig作业的最小reduce

hadoop - hdfs中的mapper和reducer运行时日志在哪里?

当我的mapreduce作业完成后,我可以转到作业历史url并在其中查看单个reducer/mapper日志。但是,我有很多映射器和缩减器,我需要将它们全部下载到我的本地驱动器以进行分析。我不知道这些日志文件在hdfs中的位置。你知道它在哪里吗? 最佳答案 我想您需要的是一个unix命令:yarnlogs-applicationId应用程序ID在MR应用程序启动期间显示,例如...15/07/1310:52:23INFOinput.FileInputFormat:Totalinputpathstoprocess:415/07/131

Hadoop eclipse 插件 2.6 - 在 : "Map/Reduce location status updater". java.lang.NullPointerException 期间发生内部错误

在EclipseHadoopplugin2.6中添加新的Hadoop位置,并尝试扩展位置时出现此错误Aninternalerroroccurredduring:"Map/Reducelocationstatusupdater".java.lang.NullPointerException请看下面的图片:http://i.imgur.com/029g7Vq.jpg.http://i.imgur.com/RIlEPH6.jpg.顺便说一句,我需要为“Map/Reduce(V2)MasterSection”配置hadoop中的哪一部分配置?对我来说,端口54333没有在Master服务器上监