草庐IT

TASK_RUNNING

全部标签

hadoop - Hbase设置配置: HMaster is not running

我正在尝试以完全分布式模式设置HBase:由1个主服务器和2个区域服务器组成。我在hbase-env.sh中设置了HBASE_MANAGES_ZK=true。hadoop集群在集群上运行,配置如下:主人:节点主人Regionserver1:node1Regionserver2:node2当我启动HBase时,我可以看到RegionServers正在启动,主服务器上的HQuorumPeer也在启动,但HMaster没有显示。请找到如下日志:掌握hbase-site.xmlhbase.masternodemaster.hbasecluster.com:60000Thehostandport

hadoop - 能否在 Hadoop 集群中的 Map Task 中启动特定进程?

我使用具有一个节点的Hadoop和YARN集群。所有hadoop和yarn守护进程都在这个节点中启动。我还使用ApacheNutch1.15分布式爬网启动了一个获取步骤,成功完成了注入(inject)和生成步骤。我正在尝试使用Selenium3.149.54FirefoxDriver在YarnChild容器上运行的maptask中运行Firefox浏览器。Firefox进程启动,但弹出一个窗口,提示Firefox配置文件丢失或无法访问,maptask被阻止,直到我关闭该窗口。Selenium3.141.54FirefoxDriver使用geckodriver启动Firefox,从容器用

vector - java.lang.OutOfMemoryError : Java heap space error while running seq2sparse in mahout 错误

我正在尝试在mahout中使用k-means对一些手工制作的日期进行聚类。我创建了6个文件,每个文件中几乎没有1或2个单词的文本。使用./mahoutseqdirectory从它们中创建一个序列文件。在尝试使用./mahoutseq2sparse命令将序列文件转换为向量时,出现java.lang.OutOfMemoryError:Javaheapspace错误。序列文件大小为0.215KB。命令:./mahoutseq2sparse-imokha/output-omokha/vector-ow错误日志:SLF4J:ClasspathcontainsmultipleSLF4Jbindin

Hadoop reducer : How to ensure the reducers are evenly running over a number of nodes

我有一个场景,我不确定减少处理器的位置。i)我有一个输入文本文件,它有1到4之间平衡范围内的1000个整数。ii)让我们假设有一个4节点集群,每个节点有12个槽,其中4个分配为reducer-总共有16个reduce槽iii)我在驱动程序中设置了reducer的数量:jobConf.setNumReduceTasks(4);iii)最后我有一个分区方法是publicclassMyPartitionerextendsPartitioner{@OverridepublicintgetPartition(Textkey,Textvalue,intnumPartitions){returnIn

hadoop - 并行运行多个 map task

我正在使用hadoop2.0。当我使用job.setNumMapTasks更改maptask的数量时,数量符合预期(输出文件夹中的序列文件数量和容器数量),但它们不会并行运行,但一次只有2个。例如,当我将map任务的数量设置为5时,它会先执行其中的2个,然后再执行2个,然后再执行1个。我有一个8核系统,想充分利用它。一些在线搜索(包括StackOverflow)似乎提出了一些建议,我尝试了以下方法:调整了mapred-site.xml中的参数“mapred.tasktracker.map.tasks.maximum”来设置并行运行的任务数。我将其设置为8。减少了参数“mapred.ma

eclipse 中的 java.lang.NoSuchFieldError : IBM_JAVA error while running hadoop 2. 2.0

Exceptioninthread"main"java.lang.NoSuchFieldError:IBM_JAVAatorg.apache.hadoop.security.UserGroupInformation.getOSLoginModuleName(UserGroupInformation.java:303)atorg.apache.hadoop.security.UserGroupInformation.(UserGroupInformation.java:348)atorg.apache.hadoop.fs.FileSystem$Cache$Key.(FileSystem.

shell - Oozie Job 仍处于 RUNNING 状态

我正在尝试在HDP集群上运行简单的oozie作业。执行oozie后,job保持Running状态。这是我的Workflow.xml${jobTracker}${nameNode}sqoopimport--connectjdbc:mysql://localhost:3306/test--tabletesting--split-byerr_dt--hive-import--hive-tabletesting-m1hive-site.xmlmysql-connector-java.jarActionfailed以下是正在生成的日志..2015-04-0714:33:32,792INFOAct

amazon-web-services - 亚马逊 S3 错误代码 : 400 while running mr-job on EMR

在EMR上运行自定义jar时出现此错误。Exceptioninthread"main"com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.model.AmazonS3Exception:BadRequest(Service:AmazonS3;StatusCode:400;ErrorCode:400BadRequest;RequestID:B042BB0B40A75966),S3ExtendedRequestID:vr/DUr8HD3xjomauyzqvVdGuW3fHBP8PDUmTIAoVLUxrmsxh9H+OS

hadoop - Spark : Minimize task/partition size skew with textFile's minPartitions option?

我正在通过sc.textFile("/data/*/*/*")之类的方式将数万个文件读入rdd>一个问题是这些文件中的大多数都是微小的,而其他的则巨大。这会导致任务不平衡,从而导致各种众所周知的问题。我能否通过sc.textFile("/data/*/*/*",minPartitions=n_files*5)读取数据来拆分最大的分区,其中n_files是输入文件的个数吗?如约定elsewhere在stackoverflow上,minPartitions被传递到hadooprabithole,并在org.apache.hadoop.mapred.TextInputFormat.getSp

performance - "time spent by map task"在 Hadoop 上包括什么?

Hadoop作业成功后,会显示各种计数器的摘要,请参见下面的示例。我的问题是Totaltimespentbyallmaptasks计数器中包含什么,特别是在映射器作业不是节点本地的情况下,是否包含数据复制时间?17/01/2509:06:12INFOmapreduce.Job:Counters:49FileSystemCountersFILE:Numberofbytesread=2941FILE:Numberofbyteswritten=241959FILE:Numberofreadoperations=0FILE:Numberoflargereadoperations=0FILE:N