跳到主要内容

程序包任务(Flink/Spark Jar、PySpark以及Ray Job)

程序包任务开发是运行自定义Jar任务为主,用户可以通过上传自定义Jar包、配置任务参数以及运行资源参数等;

  1. 点击左侧导航数智开发-程序包任务进入程序包任务管理页,可以看到当前工作空间下的所有的程序包任务以及每个任务下的历史版本。

  1. 点击添加任务按钮,在弹出的界面上设置任务名、处理引擎、选择应用包、设置主类、参数、以及配置项等信息。

处理引擎包括:Flink、Spark 和 Ray。选择 Spark 后,可以选择 Spark AppJar 类型以及 PySpark 方式;选择 Ray 后,可以选择 Ray Runtime Env 包,且该包只能使用 .zip 格式。

  1. 添加完成的任务,右侧操作栏有申请上线按钮出现,点击申请上线按钮,可以申请任务上线审批。

  1. 任务更新。点击操作栏的编辑按钮,可以对当前任务发布一个新的版本。更新后,出现新的申请上线按钮,可以再次进行上线申请。

  1. 申请上线后,可以在生产任务-发布审批界面看到,管理员可以对其继续审批处理。