前提条件

请先将所要依赖的程序包通过“数据管理>程序包管理”页面上传至对应的OBS桶中。具体操作请参考创建程序包。

界面说明

• 左侧导航栏

  在创建Spark作业页面，左侧导航栏包括“队列”页签和“程序包”页签。

  图1 Spark作业编辑页面导航栏
  

  表1 左侧导航栏说明

  序号	页签/按键	页签/按键名称	描述
  1		队列	显示已有的队列。
  2		程序包	显示已有的程序包。
  3		创建	创建队列/程序包。
  4		刷新	包括刷新已有的队列和程序包列表。
  5		搜索	在程序包页签，可以输入程序包名称进行搜索。

• 作业编辑窗口

  在作业编辑窗口，可以选择使用“表单模式”或者“API模式”进行参数设置。

  以下以“表单模式”页面进行说明，“API模式”即采用API接口模式设置参数及参数值，具体请参考《数据湖探索API参考》。

  • 选择运行队列：具体参数请参考表2。
    图2 创建Spark作业-选择运行队列
    

    表2 运行队列参数说明

    参数名称	参数描述
    所属队列	下拉选择要使用的队列。

  • 作业配置：具体参数请参考表3。
    图3 创建Spark作业-作业配置
    

    表3 作业配置参数说明

    参数名称	参数描述
    作业名称	设置作业名称。
    应用程序	选择需要执行的程序包。包括“.jar”和“.py”两种类型。
    主类	输入主类名称。当应用程序类型为“.jar”时，主类名称不能为空。
    应用程序参数	用户自定义参数，多个参数请以Enter键分隔。
    Spark参数	以“key=value”的形式设置提交Spark作业的属性，多个参数以Enter键分隔。具体参数请参考Spark Configuration。
    依赖jar包	运行spark作业依赖的jars。可以输入jar包名称，也可以输入对应的OBS路径，格式为：obs://桶名/包名。
    依赖Python文件	运行spark作业依赖的py-files。可以输入Python文件名称，也可以输入对应的OBS路径，格式为：obs://桶名/文件名。
    其他依赖文件	运行spark作业依赖的其他files。可以输入依赖文件名称，也可以输入对应的OBS路径，格式为：obs://桶名/文件名。
    依赖分组	在创建程序包时，如果选择了分组，在此处选择对应的分组，则可以同时选中该分组中的所有程序包和文件。创建程序包操作请参考创建程序包。
    访问元数据	是否通过Spark作业访问元数据。具体请参考《数据湖探索开发指南》。
    是否重试	作业失败后是否进行重试。 选择“是”需要配置以下参数： “最大重试次数”：设置作业失败重试次数，最大值为“100”。
    高级配置	暂不配置 现在配置：包括以下两项参数 选择依赖资源：具体参数请参考表4。 计算资源规格：具体参数请参考表5。

    图4 创建Spark作业-高级配置
    

    表4 选择依赖资源参数说明

    参数名称	参数描述
    Module名称	DLI系统提供的用于执行跨源作业的依赖模块，访问各个不同的服务，选择不同的模块： CloudTable/MRS HBase: sys.datasource.hbase CloudTable/MRS OpenTSDB: sys.datasource.opentsdb RDS MySQL: sys.datasource.rds RDS PostGre: sys.datasource.rds DWS: sys.datasource.dws CSS: sys.datasource.css
    资源包	运行spark作业依赖的jar包。

    表5 计算资源规格参数说明

    参数名称	参数描述
    资源规格	下拉选择所需的资源规格。系统提供3种资源规格供您选择。资源规格中如下配置项支持修改： Executor内存 Executor CPU核数 Executor个数 driver CPU核数 driver内存 最终配置结果以修改后数据为准。
    Executor内存	在所选资源规格基础上自定义Executor内存规格。
    Executor CPU核数	在所选资源规格基础上自定义Executor CPU核数。
    Executor个数	在所选资源规格基础上自定义Executor个数。
    driver CPU核数	在所选资源规格基础上自定义Driver CPU核数。
    driver内存	在所选资源规格基础上自定义Driver内存规格。

    

    Spark作业参数计算：

    • CU数=driver CPU核数+Executor个数*Executor CPU核数
    • 内存数=driver内存+(Executor个数*Executor内存）

创建Spark作业步骤

1. 在Spark作业编辑页面中，输入相关参数，具体请参考关于图3的说明。
2. 单击Spark作业编辑页面右上方“执行”，提交作业，页面显示“批处理作业提交成功”。
3. （可选）可在“Spark作业”管理页面查看提交作业的状态及日志。
   

   作业执行成功后，作业记录只保存6小时。