更新时间:2026-06-11 GMT+08:00
分享

变量管理

操作场景

FlinkServer支持在SQL作业中创建变量,这些变量可以在建表语句的WITH子句中替代常量。

约束与限制

  • 变量只能在SQL作业中使用,且只能在建表语句的WITH属性中使用。
  • 变量仅在当前应用生效,不支持跨应用使用。
  • 私有变量仅创建者可以查看、编辑、使用和删除。
  • 密文变量无法查看原值。
  • 本章节适用于MRS 3.6.0-LTS.1及以后版本。

创建变量

  1. 访问Flink WebUI,请参考访问FlinkServer WebUI界面
  2. 选择“系统管理 > 变量管理”,进入变量管理页面。
  3. 单击“新增变量”,参考表1 新增变量信息填写变量信息,配置完成后,单击“确定”。

    表1 新增变量信息

    参数名称

    参数描述

    变量

    变量的名称和变量值。

    类型

    密文或者明文。密文无法查看,显示为******。

    使用范围

    私有或者公开。

    • 公开变量其他有权限的用户可以查看编辑使用删除。
    • 私有变量只有创建用户可以查看编辑使用删除。

    变量的“类型”为“密文”时,建议将密文的使用范围设置为“私有”。

    描述

    变量的描述信息。

  4. 变量创建完成后,可以在SQL作业中建表的WITH属性中使用已创建的变量,示例如下:

    CREATE TABLE MyUserTable(
      c_customer_sk INTEGER,
      c_customer_name VARCHAR(32)
    ) WITH(
      'connector' = 'jdbc',
      'url' = '${url}',
      'table-name' = 'customer_t1',
      'username' = '${user}',
      'password' = '${password}'
    );

相关文档