草庐IT

application_name

全部标签

apache-spark - 如何使用 APPLICATION ID 提交 YARN 作业

我想知道YARNCLI是否提供了使用上一次执行生成的APPLICATION_ID重新提交YARN应用程序的可能性。例子:/opt/mapr/spark/spark-2.1.0/bin/spark-submit--num-executors5--executor-memory2G--executor-cores2--masteryarn--deploy-modecluster--files/opt/mapr/hive/hive-2.1/conf/hive-site.xml--classcom.cisco.sdp.cdx.processing.DenormSchedulerJSONDeno

hadoop - 在 YARN 集群的特定节点上运行我自己的 application master

首先,我使用的是Hadoop-2.6.0。我想在YARN集群中的特定节点上启动我自己的appmaster,以便在预定的IP地址和端口上打开服务器。为此,我编写了一个驱动程序,在其中创建了一个ResourceRequest对象并调用了setResourceName方法来设置主机名,并将其附加到ApplicationSubmissionContext对象通过调用setAMContainerResourceRequest方法。我尝试了几次,但无法在特定节点上启动AppMaster。搜索代码后,我发现RMAppAttemptImpl使我在ResourceRequest中设置的内容无效,如下所示

hadoop - Fi-Ware 宇宙 : Name node is in safe mode

我正在尝试删除我的Cosmos帐户中的一个文件夹,但我得到了SafeModeException:#hadoopfs-rmr/home//inputrmr:org.apache.hadoop.hdfs.server.namenode.SafeModeException:Cannotdelete/user//input.Namenodeisinsafemode 最佳答案 在启动期间,Namenode从fsimage加载文件系统状态并编辑日志文件。然后它等待数据节点报告它们的block,这样它就不会过早地开始复制block,尽管集群中已经

java - ChainReducer.setReducer 方法抛出错误 "ChainReducer is not applicable for the arguments"

我有两个映射器类。所以使用ChainMapper.addMapper方法添加Mapper,使用ChainReducer.setReducer方法设置Reducer。ChainMapper.addMapper方法正常但是Chain.setReducer方法抛出语法错误ThemethodsetReducer(Job,Class,Class,Class,Class,Class,Configuration)inthetypeChainReducerisnotapplicableforthearguments(JobConf,Class,Class,Class,Class,Class,boole

hadoop - 运行 YARN 应用程序时获取 "User [dr.who] is not authorized to view the logs for application <AppID>"

我在HDP2.5集群中使用ApacheTwill运行自定义Yarn应用程序,但是当我转到我的容器网页时,我无法看到我自己的容器日志(syslog、stderr和stdout):当我导航到此页面时,登录名也从我的kerberos更改为“dr.who”。但是我可以看到map-reduce作业的日志。Hadoop版本为2.7.3,集群启用了yarnacl。 最佳答案 我在使用hadoopui时遇到了这个问题。我在this中找到doc,hadoop.http.staticuser.user默认设置为dr.who,您需要将其包含在相关设置文件

hadoop - yarn 中的 "Application priority"

我正在使用Hadoop2.9.0。是否可以在YARN中提交具有不同优先级的作业?根据一些JIRA票据,应用程序优先级似乎已经实现。我尝试使用YarnClient,并在提交作业之前为ApplicationSubmissionContext设置优先级。我还尝试使用CLI和updateApplicationPriority。但是,应用程序优先级似乎没有任何变化,它始终保持为0。我是否误解了YARN的ApplicationPriority概念?我看到了一些关于设置队列优先级的文档,但对于我的用例,我需要一个队列中的所有作业。将不胜感激任何对我的理解的澄清,或对我可能做错了什么的建议。谢谢。

ModuleNotFoundError: No module named ‘transformers‘,已经安装了transformers库

明明已经安装了transformers库了,运行代码时却说找不到。先说明我的环境。系统:windowsIDE:pycharm框架:PyTorch包管理:Anaconda我用的windows环境跑的模型,有时候重新开机,会出现说我没有安装transformers库,之前重开几次就可以了没太在意,今天终于知道原因了。。。我这里的原因是:没有切换到pytorch环境(对应项目的环境,我这里起的名字就叫pytorch),还在base环境,因此程序返回说没有找到transformers库。1.先排查你的原因是否和我一样:输入以下命令,看你所在的环境condainfo-e比如我的是显示这个表示我还在bas

hadoop - Cloudera CDH4 : Can't add a host to my cluster because canonical name is not consistent with hostname

我正在使用Ubuntu12.04LTS在4节点集群上安装CDH4。我能够安装cloudera管理器并在主机上启动单节点集群。但是,一旦我添加了一个新主机,CM就会说它运行状况不佳并抛出以下错误:“从Java进程检查时,此主机的主机名和规范名称不一致。”我修改了master和所有主机上的/etc/hosts的内容,以包含IP地址,后跟每台机器的FQDN。我是否还需要设置一个DNS服务器才能完成这项工作? 最佳答案 您不一定需要设置DNS服务器才能使其正常工作,但正向和反向DNS必须明确匹配Hadoop才能正常运行。Hadoop操作书有

hadoop - Amazon EMR Application Master Web UI?

我已经开始使用HadoopYARN(AMI3.3.1)在AmazonEMR上运行PIG作业,但是由于Yarn中不再有作业跟踪器,我似乎无法找到WebUI以便我可以跟踪MapReduce作业的Mappers和Reducers的数量,当我尝试访问资源管理器UI页面中提供的ApplicationMaster链接时,我被告知该页面不存在(下面提供的图片)。有谁知道我如何通过我的网络浏览器访问一个UI,它会根据映射器、reducer的数量和每个完成的百分比等向我显示当前的工作状态?谢谢 最佳答案 从ResourceManager网页单击App

java - Cassandra 错误 :Invalid method name "describe local ring"

我正在使用java在hadoop中开发一个项目。当我在本地集群上运行我的代码(jar)时它工作正常但是当我在亚马逊多集群上运行它时它会给出异常...我的mapreduce作业代码....job.setJarByClass(ReadActivityDriver.class);job.setMapperClass(ReadActivityLogMapper.class);job.setReducerClass(ReadActivityLogReducer.class);job.setMapOutputKeyClass(Text.class);job.setMapOutputValueCla