You need to enable JavaScript to run this app.
文档中心
大数据研发治理套件(私有化)

大数据研发治理套件(私有化)

复制全文
下载 pdf
湖仓分析一体服务LAS引擎
LAS Java Flink任务
复制全文
下载 pdf
LAS Java Flink任务

LAS Java Flink任务适用于实时任务开发场景,支持引用资源Jar包的方式。

新建任务

  1. 登录DataLeap控制台。
  2. 选择数据开发 > 任务开发,进入任务开发页面。
  3. 单击新建任务 > 数据开发 > LAS > 流式数据LAS Java Flink按钮,进行任务类型选择。
  4. 设置任务基本信息,单击确定按钮,完成创建。
    Image

编辑任务

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

参数设置

  1. 单击右侧侧边栏的参数设置,进入参数设置页面。
    Image
  2. 设置任务参数信息后,单击保存图标,完成草稿保存。

相关参数配置说明,请参见“参数设置”。

最近更新时间:2025.03.19 19:31:07
这个页面对您有帮助吗?
有用
有用
无用
无用