更新时间:2022-12-14 GMT+08:00

在Flink WebUI创建数据连接

操作场景

通过数据连接,访问不同的数据服务,当前FlinkServer支持HDFS、Kafka类型的数据连接。

创建数据连接

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 选择“系统管理 > 数据连接管理”,进入数据连接管理页面。
  3. 单击“创建数据连接”,在弹出的页面中选择数据连接类型,参考表1填写信息,单击“确定”,完成数据连接创建。

    表1 创建数据连接信息

    参数名称

    参数描述

    示例

    数据连接类型

    选择数据连接的类型,包含HDFS、Kafka。

    -

    数据连接名称

    数据连接的名称。只能包含英文字母、数字和下划线,且不能多于100个字符。

    -

    集群连接

    配置管理里的集群连接名称。

    HDFS类型数据连接需配置该参数。

    -

    Kafka broker

    Kafka Broker实例的连接信息,格式为“IP地址:端口”,多个实例之间通过逗号分割。

    Kafka类型数据连接需配置该参数。

    192.168.0.1:21005,192.168.0.2:21005

    认证类型

    • SIMPLE:表示对接的服务是非安全模式,无需认证。
    • KERBEROS:表示对接的服务是安全模式,安全模式的服务统一使用Kerberos认证协议进行安全认证。

    Kafka类型数据连接需配置该参数。

    -

编辑数据连接

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 选择“系统管理 > 数据连接管理”,进入数据连接管理页面。
  3. 在待修改项的“操作”列单击“编辑”,在弹出的页面中参考表1修改连接信息,单击“确定”完成修改。

测试数据连接

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 选择“系统管理 > 数据连接管理”,进入数据连接管理页面。
  3. 在待测试项的“操作”列单击“测试”进行测试。

搜索数据连接

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 选择“系统管理 > 数据连接管理”,进入数据连接管理页面。
  3. 在页面右上角,用户可以根据“名称”进行搜索查看数据连接。

删除数据连接

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 选择“系统管理 > 数据连接管理”,进入数据连接管理页面。
  3. 在待删除项的“操作”列单击“删除”,在弹出的页面中单击“确定”完成删除。