# 任务开发
任务开发管理:包含新建开发任务、修改、删除开发任务,开发任务查询,创建副本,开发任务发布,流程配置,开发任务测试等功能
# 新建开发任务
打开任务模板界面,点击新建按钮出现弹窗,输入任务名称和任务类型必填项,点保存。
备注:任务类型必须与算法类型保持一致,即spark任务选择spark组件算法,flink任务选择flink组件算法,目前采用通用算法组件时在建立任务时任务类型选spark任务。
填写完成后点击保存按钮,会自动跳转到流程配置界面
# 流程配置
从左侧流程组件栏拖拽节点到画布中
从组件右侧或下方的端点拖出线条,连接到其他组件的左侧和上方端点上,注意计算组件和算法组件的端点可以连接多个连线,其他组件则是一个端点只能连接一条连线
画布左上方可调整线条样式,十字箭头按钮用于恢复画布中心位置,画布中滑动鼠标滑轮可放大缩小
点击输入源节点、输出源配置相关属性
点击算法组件节点,在属性面板选择相应算法
# 任务测试
点击右上方测试按钮,运行该流程检验其是否能正常运行 运行日志弹框,显示“打包成功,开始执行”时点击上传测试数据,确认
# spark/flink任务IOT输入配置图
# spark任务csv文件输入配置图
# 修改开发任务
点击修改,可以修改模板名称、任务类型、备注等。 点击流程配置,可以修改流程配置。
# 删除开发任务
勾选任务前方的选择框,点击删除按钮可以删除开发任务。
# 创建副本
根据所选开发任务复制创建新的开发任务。
# 任务发布
说明:任务发布之后不能修改流程配置中的计算组件中的算法包。
任务调度新建调度任务只能选择已发布的任务开发模板,如果开发任务没有发布,调度环节新建任务时查询不到。