LAS Java Flink任务适用于实时任务开发场景,支持引用资源Jar包的方式。
新建任务
- 登录DataLeap控制台。
- 选择数据开发 > 任务开发,进入任务开发页面。
- 单击新建任务 > 数据开发 > LAS > 流式数据LAS Java Flink按钮,进行任务类型选择。
- 设置任务基本信息,单击确定按钮,完成创建。

编辑任务
- 引用资源
任务创建完成后,直接进入任务配置页面,设置引用资源。
- 选择Jar包:输入关键字搜索并选择已上传的jar包文件。
- 执行引擎:从下拉列表中选择LAS Flink。
- Main Class:填写主类,例如:com.bytedance.flinkdemo.KafkaWordCount。
Jar包要先上传,才能选择。相关创建操作请参见“新建资源文件”。
- Flink运行参数
Flink运行参数与Native Java Flink引擎运行参数基本一致,操作详见“参数设置”表中的数据源登记说明。 - 用户自定义参数
用户自定义参数,填写实时数据来源端相关实例信息,例如 kafka 消息队列接入时,需要填写 Topic、接入点地址等参数信息。
- 单行编辑模式:填写 key-value,key值只允许字母、数字、小数点、下划线和连字符。
- 脚本编辑模式:通过JSON、Yaml的格式填写运行参数。
参数设置
- 单击右侧侧边栏的参数设置,进入参数设置页面。

- 设置任务参数信息后,单击保存图标,完成草稿保存。
相关参数配置说明,请参见“参数设置”。