文档简介:
用户可将自己开发的程序提交到MRS中,执行程序并获取结果。本章节教您在MRS集群页面如何提交一个新的作业。
前提条件
已完成如下信息。
MRS集群处理的数据源来源于OBS或HDFS,HDFS是Hadoop分布式文件系统(Hadoop Distributed File System),OBS即对象存储服务,是一个基于对象的海量存储服务,为客户提供海量、安全、高可靠、低成本的数据存储能力。MRS可以直接处理OBS中的数据,客户可以基于管理控制台Web界面和OBS客户端对数据进行浏览、管理和使用,同时可以通过REST API接口方式单独或集成到业务程序进行管理和访问数据。
用户创建作业前需要将本地数据上传至OBS系统,MRS使用OBS中的数据进行计算分析。当然MRS也支持将OBS中的数据导入至HDFS中,使用HDFS中的数据进行计算分析。数据完成处理和分析后,您可以将数据存储在HDFS中,也可以将集群中的数据导出至OBS系统。需要注意,HDFS和OBS也支持存储压缩格式的数据,目前支持存储bz2、gz压缩格式的数据。
操作步骤
步骤1登录MRS管理控制台。
步骤2选择“集群列表 > 现有集群”,选中一个运行中的集群并单击集群名,进入集群信息页面。
步骤3单击“作业管理”,进入“作业管理”页签。
步骤4在“作业”页签中单击“添加”,进入新增作业页面。
此处MapReduce仅为示例,请根据业务类型,选择不同的作业类型。
步骤 5参考表4-20配置作业信息。
表4-20作业配置信息
参数 | 参数说明 |
作业类型 | 支持的作业类型,请根据业务类型选择: |
l MapReduce | |
l Spark | |
l Spark Script | |
l Hive Script | |
说明 | |
只有创建集群时选择了Spark和Hive组件,并且集群处于运行中,才能新增Spark和Hive类型的作业。Spark Script作业只支持运行Spark SQL程序,Spark支持运行Spark Core、Spark SQL程序。 | |
作业名称 | 作业名称,只能由字母、数字、中划线和下划线组成,并且长度为1~64个字符。 |
说明 | |
建议不同的作业设置不同的名称。 | |
执行程序路径 | 执行程序Jar包地址,需要满足如下要求: |
l 最多为1023字符,不能包含;|&>,<'$特殊字符,且不可为空或全空格。 | |
l 执行程序路径可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 | |
− OBS:以“s3a://”开头。示例:s3a://wordcount/program/hadoop-mapreduce-examples-2.7.x.jar | |
− HDFS:以“/user”开头。 | |
l Spark Script需要以“.sql”结尾,MR和Spark需要以“.jar”结尾。sql、jar不区分大小写。 | |
执行程序参数 | 程序执行的关键参数,该参数由用户程序内的函数指定,MRS只负责参数的传入。 |
配置方法:包名.类名 | |
最多为2047字符,不能包含;|&><'$特殊字符,可为空。 | |
数据输入路径 | 数据输入地址 |
数据可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 | |
l OBS:以“s3a://”开头。 | |
l HDFS:以“/user”开头。 | |
最多为1023字符,不能包含;|&>,<'$特殊字符,可为空。 | |
输出路径 | 数据输出地址 |
数据可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 | |
l OBS:以“s3a://”开头。 | |
l HDFS:以“/user”开头。 | |
最多为1023字符,不能包含;|&>,<'$特殊字符,可为空。 | |
日志路径 | 作业日志存储地址,该日志信息记录作业运行状态。 |
数据可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 | |
l OBS:以“s3a://”开头。 | |
l HDFS:以“/user”开头。 | |
最多为1023字符,不能包含;|&>,<'$特殊字符,可为空。 |
OBS路径支持“s3a://”,默认使用“s3a://”。
OBS路径不支持KMS加密的文件或程序。
使用OBS路径时,单文件大小必须小于5GB。
OBS和HDFS的全路径长度小于等于1023字符。
步骤 6确认作业配置信息,单击“确定”,完成作业的新增。
作业新增完成后,可对作业进行管理。
默认每个集群最多支持运行中的作业数量为10。