前提条件

• 请先将所要依赖的程序包通过“数据管理>程序包管理”页面上传至对应的OBS桶中。具体操作请参考创建程序包。
• 创建Spark作业，访问其他外部数据源时，如访问OpenTSDB、HBase、Kafka、DWS、RDS、CSS、CloudTable、DCS Redis、DDS Mongo等，需要先创建跨源连接，打通作业运行队列到外部数据源之间的网络。
  • 当前Spark作业支持访问的外部数据源详情请参考跨源连接和跨源分析概述。
  • 创建跨源连接操作请参见增强型跨源连接（推荐）。

    创建完跨源连接后，可以通过“队列管理”页面，单击“操作”列“更多”中的“测试地址连通性”，验证队列到外部数据源之间的网络连通是否正常。详细操作可以参考测试地址连通性。

界面说明

• 左侧导航栏

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

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

  表1 左侧导航栏说明

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

• 作业编辑窗口

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

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

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

    表2 运行队列参数说明

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

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

    表3 作业配置参数说明

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

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

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

    参数名称	参数描述
    Module名称	DLI系统提供的用于执行跨源作业的依赖模块访问各个不同的服务，选择不同的模块： CloudTable/MRS HBase: sys.datasource.hbase DDS：sys.datasource.mongo CloudTable/MRS OpenTSDB: sys.datasource.opentsdb DWS: sys.datasource.dws RDS MySQL: sys.datasource.rds RDS PostGre: sys.datasource.rds DCS: sys.datasource.redis CSS: sys.datasource.css DLI内部相关模块： sys.res.dli-v2 sys.res.dli sys.datasource.dli-inner-table
    资源包	运行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核数

      注意：因为本身DLI集群管理面和driver都会占用一部分CU资源，“Executor个数*Executor CPU核数”实际要小于队列的计算资源CU数。

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

创建Spark作业步骤

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