草庐IT

application-size

全部标签

python - hadoop 流 : where are application logs?

我的问题类似于:hadoopstreaming:howtoseeapplicationlogs?(答案中的链接目前无法使用。所以我必须再次发布它并提出一个额外的问题)我可以在/usr/local/hadoop/logs路径下看到所有hadoop日志但是我在哪里可以看到应用程序级别的日志?例如:reducer.py-importlogging....logging.basicConfig(level=logging.ERROR,format='MAP%(asctime)s%(levelname)s%(message)s')logging.error('Test!')...我在stderr

apache-spark - Yarn 的 "Application Type"在哪里/如何定义?

如果向ApacheYARN集群提交新作业,状态页面通常会指示作业实际是如何提交的(除其他事项外):ApplicationType:SPARK这表明用户很可能使用spark-submit向资源管理器发布了一个新作业。是否可以像更改应用程序名称一样通过参数更改该字符串的值? 最佳答案 应用类型在Spark设置yarn应用上下文时设置。AFAIK,无法更改某些配置的方式。如果它真的很重要,您将不得不在源代码中覆盖它。下面的实现,https://github.com/apache/spark/blob/01c3dfab158d40653f8

hadoop - 配置单元 : The application won't work without a running HiveServer2

我是这个领域的新手。我正在检查CDH5.8快速启动VM以尝试一些基本的hive/impala示例。但是我遇到了一个问题,当我打开HUE时出现以下错误。我搜索了解决方案,但没有找到任何可以解决我的问题的方法。Configurationfileslocatedin/etc/hue/conf.emptyPotentialmisconfigurationdetected.FixandrestartHue.HiveTheapplicationwon'tworkwithoutarunningHiveServer2.我检查过,它已启动并正在运行。尝试重新启动服务和CDH,没有帮助。HiveServe

hadoop - 限制 Application Master 请求的资源的属性

HadoopMRv2(Yarn)中是否有一个属性允许我们专门操纵ApplicationMaster请求的资源量(VCores和堆内存)?或者ApplicationMaster会动态评估所需的资源(基于每个应用程序)并为容器请求相应的资源? 最佳答案 以下属性可用于为YARNApplicationmaster设置VCors和HeapMemory。yarn.app.mapreduce.am.resource.mb8192yarn.app.mapreduce.am.resource.cpu-vcores1yarn.app.mapreduc

hadoop - 如何知道 Amazon EMR 实例的 MIN_CONTAINER_SIZE?

如何在AmazonEMR集群上获取MIN_CONTAINER_SIZE的默认设置?因为我想通过这个公式来计算EMR上每个节点的内存使用情况RAM-per-container=max(MIN_CONTAINER_SIZE,(TotalAvailableRAM)/containers))谢谢! 最佳答案 在EMR4.x中,默认的最小容器大小为256M。但是上限将受到每个实例类型的节点管理器可用内存的限制(http://docs.aws.amazon.com/ElasticMapReduce/latest/ReleaseGuide/emr

java - 如何调整hadoop集群中的 "DataNode maximum Java heap size"

我在google中搜索以查找有关如何调整值的信息-DataNodemaximumJavaheapsize,除了这个-https://community.hortonworks.com/articles/74076/datanode-high-heap-size-alert.htmlhttps://docs.oracle.com/cd/E19900-01/819-4742/abeik/index.html但未找到计算DataNode最大Java堆大小值的公式DataNode最大Java堆大小的默认值为1G我们将这个值增加到5G,因为在某些情况下我们从数据节点日志中看到关于堆大小的错误但这

hadoop - mapred.min.split.size

我正在尝试在MapReduce中试验这个参数,但我有一些问题。这是否符合HDFS中的大小(无论是否压缩)?还是解压后的?我猜是前者,但只是想确认一下。 最佳答案 仅当您的输入格式支持拆分输入文件时才会使用此参数。常见的压缩编解码器(如gzip)不支持拆分文件,因此将被忽略。如果输入格式确实支持拆分,那么这与压缩后的大小有关。 关于hadoop-mapred.min.split.size,我们在StackOverflow上找到一个类似的问题: https://s

Hadoop 映射器 : Appropriate input files size?

我的集群HDFSblock大小为64MB。我有包含100个纯文本文件的目录,每个文件的大小为100MB。作业的InputFormat是TextInputFormat。将运行多少个映射器?我在HadoopDeveloper考试中看到了这个问题。答案是100。其他三个答案选项是64、640、200。但我不确定100是怎么来的,或者答案是错误的。请指导。提前致谢。 最佳答案 我同意你的判断,这似乎是错误的当然除非有更多的考试问题没有发布:这些“纯”文本文件是否经过gzip压缩-在这种情况下它们不可拆分?)簇分割大小可能是64MB,但输入文

java - hadoop、 Jersey 和 JBoss : application won't start

首先,我对JBoss几乎一无所知。昨天之前从来没有接触过它,仍然不太了解它。但是,我公司的一位客户正在使用它来部署我们的应用程序,而我们的最新更新破坏了他们的配置,所以我正在努力解决它。无论如何,这是版本信息:Hadoop:2.7.2Jersey:2.3JBoss:6.1操作系统:Windows(我怀疑这是特定于操作系统的,那只是我正在处理的环境)我们最近向我们的应用程序添加了一个Hadoop连接器模块,这似乎是导致失败的原因。我已经能够重现这个问题,这里是堆栈跟踪:13:32:39,857ERROR[org.jboss.msc.service.fail](MSCservicethre

hadoop - 为什么 BytesWritable.setSize(size) 使字节空间为 1.5*size?

我正在使用hadoop编写程序。我的问题代码如下(代码在映射器中):byte[]tmp=newbyte[2];tmp[0]=0x01;tmp[1]=0x02;BytesWritableoutputKey=newBytesWritable();outputKey.set(tmp,0,2);然而,当我操作从mapper得到的reducer中的key时,却让我大吃一惊:byte[]reducerKey=key.getBytes();reducerKey如下:reducerKey[0]->0x01;reducerKey[1]->0x02;reducerKey[2]->0x00;为什么我输入的t