草庐IT

java - Hadoop Job 在最后几个百分比时真的很慢吗?

我一直在Hadoop集群版本0.20.2上运行作业,直到最近一切都正常,没有任何原因,也没有任何错误,maptask的最后几个百分比比作业的其余部分花费的时间长得多,其中最后2%需要30秒,其余工作不到30秒。无论输入大小如何,现在所有作业都会发生这种情况这是一个输入数据为4GB的示例,在此问题之前整个作业从提交到完成需要37秒,但现在需要一分钟多:14/08/0120:57:12INFOinput.FileInputFormat:Totalinputpathstoprocess:114/08/0120:57:12INFOmapred.JobClient:Runningjob:job_

hadoop - 避免 "The number of tasks for this job 100325 exceeds the configured limit"错误

我有一个每周在生产集群上运行的Pig脚本。在上次运行中我得到了以下错误org.apache.pig.backend.executionengine.ExecException:ERROR6017:Jobfailed!Error-Jobinitializationfailed:java.io.IOException:Thenumberoftasksforthisjob100325exceedstheconfiguredlimit100000atorg.apache.hadoop.mapred.JobInProgress.initTasks(JobInProgress.java:719)a

hadoop - 不允许Datanode连接到Hadoop 2.3.0集群中的Namenode

我正在尝试建立一个ApacheHadoop2.3.0集群,我有一个主节点和三个从节点,从节点列在$HADOOP_HOME/etc/hadoop/slaves文件中,我可以从从节点远程登录到端口9000上的主名称节点,但是当我在任何从节点上启动数据节点时,我得到以下异常。2014-08-0308:04:27,952FATALorg.apache.hadoop.hdfs.server.datanode.DataNode:InitializationfailedforblockpoolBlockpoolBP-1086620743-xx.xy.23.162-1407064313305(Data

java.io.IOException : File/tmp/hadoop-eo/mapred/system/jobtracker. 信息只能复制到 0 个节点,而不是 2 个

当我在我们的主机上部署hadoopnamenode时,我们一次又一次地遇到异常,任何人都可以帮助提供任何建议吗?提前致谢。2014-08-0509:08:00,538INFOorg.apache.hadoop.hdfs.server.namenode.FSNamesystem:Numberoftransactions:31Totaltimefortransactions(ms):1NumberoftransactionsbatchedinSyncs:0Numberofsyncs:21SyncTimes(ms):172014-08-0509:08:00,542INFOorg.apache

hadoop - 如何在 Pig 中拆分具有 '\t' 和 ',' 值的文本文件

我想将具有制表符和逗号分隔值的文本文件转换为PIG中的完全逗号分隔值。我正在使用ApachePig版本0.11.1.,我尝试使用以下代码并尝试使用FLATTEN、TOKENIZE。但我不能把它变成完整的CSV文件。a=load'/home/mansoor/Documents/ip.txt'usingPigStorage(',')as(key:chararray,val1:chararray,val2:chararray);b=FOREACHa{key=STRSPLIT(key,'\t');GENERATEkey;}以下是我的文本文件输入:M12345M123456,M234567,M9

java - 如何在 hadoop 中管理连接 - MultipleInputPath

在mapsidejoin之后,我在Reducer中得到的数据是key------bookvalues6eraser=>book2pen=>book4pencil=>book5我基本上想做的是eraser=>book=2/6pen=>book=4/6pencil=>book=5/6我最初做的是这样的publicvoidreduce(Textkey,Iterablevalues,Contextcontext)throwsIOException,InterruptedException{System.out.println("key------"+key);System.out.printl

hadoop - 关于分布式运行在hadoop上的hbase

Hadoop版本=2.4.1hbase版本=0.98.6我已经在下面的conf上启动并运行得很好:107.108.86.119-hadoopnamenode,SecondaryNameNode107.109.155.100-datanode1107.109.155.102-datanode2现在我安装hbase如下conf:-107.108.86.114:-hmaster,HQuorumPeer107.109.155.100-regionserver1107.109.155.102-regionserver2当我执行jps时,以下进程正在运行:107.109.155.102:-hreg

hadoop - 使用 http 源在具有相同扩展名的 HDFS 中保存文件(不同扩展名)

我需要创建一条数据管道,其中源是HTTP,接收器是HDFS来发布数据和文件。问题是我想用与最初发送到HTTP源相同的扩展名保存文件。我用下面的脚本创建了一个流流创建httpToHdfs--defination"http|HDFS"--deploy但是当我以.gzip/.xml/.json格式上传文件时,它会将文件存储在.txt中我只想通过HTTP源复制HDFS中的文件,springxd可以吗? 最佳答案 hdfs接收器用于将基于文本的流写入hdfs。它采用名为--fileExtension的选项,您可以在其中指定文件扩展名。虽然这个

hadoop - Ganglia 监控 Hadoop 多节点集群

我想使用ganglia监控Hadoop(Hadoop版本0.20.2)多节点集群。我的Hadoop工作正常。我在阅读以下博客后安装了Ganglia---http://hakunamapdata.com/ganglia-configuration-for-a-small-hadoop-cluster-and-some-troubleshooting/http://hokamblogs.blogspot.in/2013/06/ganglia-overview-and-installation-on.html我还学习了MonitoringwithGanglia.pdf(附录BGanglia和

hadoop - 意外标记 `(' 附近的配置单元语法错误

我的Hive查询一直在抛出错误:syntaxerrornearunexpectedtoken`('我不确定下面的查询哪里出错了。你能帮帮我吗?selectA.dataA,B.dataB,count(A.nid),count(B.nid)from(selectnid,sum(dataA_count)asdataAfromtable_viewgroupbynid)ALEFTJOIN(selectnid,sum(dataB_count)asdataBfromtable_othersgroupbynid)BONA.nid=B.nidgroupbyA.dataA,B.dataB;