新建FLINK_DATASTREAM任务
本文为您介绍如何基于开源Flink实时引擎创建FLINK_DATASTREAM任务。
前提条件
权限说明
仅支持超级管理员、项目管理员和开发者创建FLINK_DATASTREAM计算任务。
步骤一：新建FLINK_DATASTREAM任务
在Dataphin首页，单击顶部菜单栏研发。
按照下图操作指引，进入新建FLINK_DATASTREAM任务对话框。
在新建FLINK_DATASTREAM任务对话框，配置任务参数。
参数
描述
任务名称
名称的命名规则如下：
只能包含小写英文字母、数字、下划线（_）。
名称的长度范围为3~62个字符。
项目内的名称不支持重复。
名称仅支持以英文字母开头。
生产环境资源队列
选择FLINK_DATASTREAM任务所在的生产环境集群。
生产环境引擎版本
选择任务运行的Flink引擎版本。Dataphin支持的引擎版本如下：
1.15.3
1.14.2
1.13.1
开发环境资源队列及引擎版本
支持选择系统默认配置或自行配置。
系统默认配置：默认选择，使用与生产环境相同的环境集群与引擎版本。
自行配置：您可自行选择开发环境任务运行的环境集群及引擎版本。若您的项目空间为Basic模式，则无需配置该配置项。
存储目录
默认选择为代码管理，同时您也可以在计算任务页面创建目标文件夹后，选择该目标文件夹为Flink_DataStream任务的目录。
选择资源
该FLINK_DATASTREAM任务依赖的资源包。
类名
使用资源的完整类名（全限定类名）。
使用模板
开启后可引用已创建的实时模板。
描述
填写对FLINK_DATASTREAM任务的简单描述，1000字符以内。
单击确定。
步骤二：预编译FLINK_DATASTREAM任务代码
在FLINK_DATASTREAM任务代码页面，单击页面左上方的预编译，校验代码任务的语法及权限问题。
预编译成功，在页面上方出现
弹窗。预编译失败，在页面上方出现
弹窗，单击页面底部Console，查看预编译失败日志。
步骤三：配置FLINK_DATASTREAM任务
单击编辑器侧边栏配置。
在配置对话框中，配置FLINK_DATASTREAM任务实时模式相关配置信息。
重要FLINK_DATASTREAM任务不支持开启离线模式。
实时模式
资源配置（必选）：配置任务生产环境和开发环境对应的资源队列、引擎版本以及任务的并行度、Task Manager数量、Job Manager Memory和Task Manager Memory信息。配置说明，请参见配置开源Flink实时模式资源。
变量配置：变量参数配置是对计算任务代码中所用的变量进行赋值，从而支持变量参数可以自动被替换为相应的变量值。配置说明，请参见实时模式变量配置。
时间参数：用于配置实时计算任务的运行时间偏移。配置说明，请参见实时模式时间参数配置。
Checkpoint配置：配置Flink SQL任务的Checkpoint，可有效的帮助当前Flink SQL任务运行意外崩溃后，重新运行程序时恢复到崩溃前的状态。配置说明，实时模式Checkpoint配置。
State配置：配置State中数据自动清理的周期。配置说明，实时模式State配置。
运行参数：可以通过配置运行参数，控制Flink应用程序的执行行为和性能。配置说明，请参见实时模式运行参数配置。
依赖文件：配置任务依赖的资源文件。配置说明，请参见实时模式依赖文件配置。
依赖关系：配置依赖关系可帮助排查调试时快速了解数据的上下游任务。配置说明，请参见实时模式依赖关系配置。
单击确定。
步骤四：提交FLINK_DATASTREAM任务
单击页面左上方的
按钮，并在提交备注对话框中填写备注信息。单击确定并提交。
说明如果项目的模式为Dev-Prod，则您需要发布FLINK_DATASTREAM任务至生产环境。具体操作，请参见管理发布任务。
后续步骤
提交成功后，您可在运维中心查看并运维FLINK_DATASTREAM任务，保证任务的正常运行。更多信息，参见查看并管理实时任务。