配置依赖管理

前提条件

准备依赖文件。如果通过“指定路径”方式将依赖上传到集群，需提前创建HDFS路径，并将jar包上传至HDFS中。

上传依赖包

1. 登录FusionInsight Manager，访问Flink WebUI，请参考访问Flink WebUI。
2. 单击“依赖管理”进入依赖管理页面。
3. 单击“添加依赖”，可参考如下添加依赖。

   表1 添加依赖

   参数	描述	示例
   是否自定义connector	是否自定义connector，根据实际需求选择： 是：文件为自定义connector依赖包。 否：文件为非自定义connector依赖包。	是
   名称	添加的依赖名称，需与上传的依赖包中connector的连接名一致。不支持上传同名依赖包。	kafka
   注册jar	jar包的上传方式： 上传文件：添加本地的jar包 指定路径：已准备好的依赖文件的HDFS路径	上传文件
   上传文件	注册jar选择为“上传文件”时，需通过该项上传本地jar文件。	-
   指定路径	注册jar选择为“指定路径”时，需通过该项输入依赖文件的HDFS路径（需提前准备好jar包上传至HDFS）。	/flink_upload_test/flink-connector-kafka-customization.jar
   描述信息	添加的依赖的描述信息。	-

4. 单击“确定”。

使用示例

• 自定义connector依赖
  1. 参考上传依赖包上传自定义connector依赖。

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

  2. 参考创建作业新建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;