MapReduce 程序

MapReduce 程序类型分为 Java、Scala、Python。

参数说明：

参数	说明
任务名称	MapReduce 程序的名称。
程序类型	支持 Java、Scala、Python。
主函数的 Class	MapReduce 程序的入口 Main class 的全路径。
主程序包	执行 MapReduce 程序的 jar 包（通过项目配置》文件管理上传）。
资源	如果其他参数中引用了资源文件，需要在资源中选择指定。
主程序参数	设置 Flink 程序的输入参数，支持自定义参数变量的替换。
选项参数	支持 --jar、--files、--archives、--conf 格式。
程序名称	设置程序的名称。一个作业流定义中的节点名称是唯一的。
任务优先级	worker 线程数不足时，根据优先级从高到低依次执行，优先级一样时根据先进先出原则执行。
Worker 分组	任务分配给 worker 组的机器执行，选择 Default，会随机选择一台 worker 机器执行。
本地参数	是 SHELL 局部的用户自定义参数，会替换脚本中 ${变量} 的内容。
超时告警	勾选超时告警、超时失败，当任务超过”超时时长”后，会发送告警邮件并且任务执行失败。
备注	描述该 MapReduce 程序的功能描述。