MAPREDUCE服务 MRS-配置FlinkServer作业中添加第三方依赖jar:使用示例

时间：2024-11-28 01:44:42

MAPREDUCE服务 MRS

使用示例

自定义connector依赖

参考上传依赖包上传自定义connector依赖。
如上传依赖名称为“kafka”，自定义connector jar包名称为“flink-connector-kafka-customization.jar”。

参考如何创建FlinkServer作业新建SQL作业，该SQL中的“connector”需填写为对应的依赖名称，如'connector' = 'kafka'。

CREATE TABLE KafkaSinkTable (`user_id` INT, `name` VARCHAR) WITH (
  'connector' = 'kafka',
  'topic' = 'test_sink6',
  'properties.bootstrap.servers' = '192.168.20.134:21005',
  'properties.group.id' = 'testGroup',
  'scan.startup.mode' = 'earliest-offset',
  'format' = 'csv'
);
CREATE TABLE datagen (`user_id` INT, `name` VARCHAR) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '5',
  'fields.user_id.kind' = 'sequence',
  'fields.user_id.start' = '1',
  'fields.user_id.end' = '1000'
);
insert INTO
  KafkaSinkTable
select
  *
from
  datagen;

上一篇：MAPREDUCE服务 MRS-使用Broker Load方式导入数据至Doris:前提条件

下一篇：MAPREDUCE服务 MRS-配置FlinkServer作业中添加第三方依赖jar:上传依赖包