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

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

复制全文
湖仓分析一体服务LAS引擎
LAS Java Flink任务
复制全文
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
这个页面对您有帮助吗?
有用
有用
无用
无用