文档

新建FLINK_DATASTREAM任务

更新时间:

本文为您介绍如何基于Fusioninsight Flink实时引擎创建FLINK_DATASTREAM任务。

前提条件

  • 在您开始执行操作前,请确认项目已开启实时引擎并已配置Fusioninsight Flink计算源。具体操作,请参见创建通用项目

  • 在您开始执行操作前,请确认已上传开发完成的Datstream作业的JAR包至Dataphin平台,具体操作,请参见上传资源及引用

权限说明

仅支持超级管理员项目管理员开发者创建FLINK_DATASTREAML计算任务。

步骤一:新建FLINK_DATASTREAM任务

  1. 在Dataphin首页,单击顶部菜单栏研发

  2. 按照下图操作指引,进入新建FLINK_DATASTREAM任务对话框。

    image.png

  3. 新建FLINK_DATASTREAM任务对话框,配置任务参数。

    参数

    描述

    任务名称

    名称的命名规则如下:

    • 只能包含小写英文字母、数字、下划线(_)。

    • 名称的长度范围为3~62个字符。

    • 项目内的名称不支持重复。

    • 名称仅支持以英文字母开头。

    生产环境资源队列

    选择FLINK_DATASTREAM任务所在的生产环境集群。

    生产环境引擎版本

    选择任务运行的Flink引擎版本。Dataphin仅支持Fusioninsight Flink实时引擎的1.15.0引擎版本。

    开发环境资源队列及引擎版本

    支持选择系统默认配置自行配置

    • 系统默认配置:默认选择,使用与生产环境相同的环境集群与引擎版本。

    • 自行配置:您可自行选择开发环境任务运行的环境集群及引擎版本。若您的项目空间为Basic模式,则无需配置该配置项。

    存储目录

    默认选择为代码管理,同时您也可以在计算任务页面创建目标文件夹后,选择该目标文件夹为Flink_DataStream任务的目录。

    image.png

    选择资源

    该FLINK_DATASTREAM任务依赖的资源包。

    类名

    使用资源的完整类名(全限定类名)。

    描述

    填写FLINK_DATASTREAM任务的简单描述。

  4. 单击确定

步骤二:预编译FLINK_DATASTREAM任务代码

在FLINK_DATASTREAM任务代码页面,单击页面左上方的预编译,校验代码任务的语法及权限问题。

说明
  • 预编译成功,在页面上方出现1弹窗。

  • 预编译失败,在页面上方出现2弹窗,单击页面底部Console,查看预编译失败日志。

步骤三:配置FLINK_DATASTREAM任务

  1. 单击编辑器侧边栏配置

  2. 在配置对话框中,配置FLINK_DATASTREAM任务实时模式相关配置信息。

    重要

    FLINK_DATASTREAM任务不支持开启离线模式

    image.png

  3. 单击确定

步骤四:提交FLINK_DATASTREAM任务

  1. 单击页面左上方的image按钮,并在提交备注对话框中填写备注信息。

  2. 单击确定并提交

    说明

    如果项目的模式为Dev-Prod,则您需要发布FLINK_DATASTREAM任务至生产环境。具体操作,请参见管理发布任务

后续步骤

提交成功后,您可在运维中心查看并运维FLINK_DATASTREAM任务,保证任务的正常运行。更多信息,参见查看并管理实时任务