未在E-Mapreduce上设置获取作业启动程序类名错误
我正在尝试运行以下命令：
--master yarn-client --driver-memory 7g --num-executors 10 --executor-memory 5g --executor-cores 1 --jars ossref://emr/checklist/jars/emr-core-0.1.0.jar ossref://emr/checklist/python/wordcount.py oss://emr/checklist/data/kddb 5 32
获取以下错误：
Tue Jun 18 10:48:58 CST 2019[LocalJobLauncherAM]信息启动emr flow launcher am...=======================================================
==系统参数===============
[]============================================================================================================Tue Jun 18 10:48:58 CST 2019[LocalJobLauncherAM]错误作业启动器类名未设置，退出。
共有1个答案
--class <class_name> --master yarn-client --driver-memory 7g --num-executors 10 --executor-memory 5g --executor-cores 1 --jars ossref://emr/checklist/jars/emr-core-0.1.0.jar ossref://emr/checklist/python/wordcount.py oss://emr/checklist/data/kddb 5 32
https://emr.aliyuncs.com/?Action=CreateJob &Name=CreateJobApiTest-SPARK &Type=SPARK &EnvParam=--class%20org.apache.spark.examples.SparkPi%20--master%20yarn-client%20%E2%80%93num-executors%202%20--executor-memory%202g%20--executor-cores%202%20/opt/apps/spark-1.6.0-bin-hadoop2.6/lib/spark-examples*.jar%2010 &FailAct=STOP &RegionId=cn-hangzhou &Common request parameters
-
我正在尝试从Java应用程序调用mapreduce作业。在以前的hadoop版本(1.x)中，我创建了一个配置对象和一个作业对象，在配置中设置mapred.Job.tracker和fs.default.name并运行作业。现在，在Hadoop2.x中，作业跟踪器不再存在，也不存在任何关于如何以编程方式运行MR1作业的文档。有什么想法吗？ 我要找的是这里给出的解释：从一个简单的Java程序调用一个m
-
在Apache Hadoop中使用job.waitForCompletion(true)方法和通过ToolRunner.run(new MyClass()，args)启动map reduce作业有什么区别？ 我通过以下两种方式执行MapReduce作业： 首先如下： 其次是： 两种方法的输出都是一样的。但是我不明白这两种方法有什么区别？哪一种比另一种更受欢迎？
-
重置应用程序和在Appium（版本：1.4.16.1）上启动应用程序时，我遇到以下错误。我正在使用Java。 组织。openqa。硒。WebDriverException:chrome不可访问（会话信息：chrome=50.0.2661.86）（驱动程序信息：chromedriver=2.18.343845（73DD713BA7FB73CBB514E62641D8C96A94682A），平台=Wi
-
减速器 自定义可写类
-
问题内容： 在此示例中，我需要获取名称作业，我有一个代码用于使用该代码获取build参数的先前值 现在，工作名称是硬编码的，我需要获得的名称将是当前工作的名称。我该怎么做？ 问题答案： Groovy Dynamic参数无法访问其余詹金斯工作所专有的常规环境变量。 这是获取工作名称的有效方法：
-
我正在使用quartz调度器来调度一个Spring批处理作业。应用程序启动时没有任何异常，但它从不激发任何作业。 它运行得很成功，但经过更多的开发后，它停止了工作。我无法弄清楚我到底改变了什么配置导致了这一点。 有谁可以建议检查点在使用“JobRepositoryFactoryBean”，如果我没有或问题在其他地方。