FlinkServer作业对接HTTP服务

操作场景

本章节提供了如何使用FlinkServer写FlinkSQL对接HTTP服务。支持对接HTTP维表。

本章节仅适用于MRS 3.6.0-LTS及之后的版本。

前提条件

• 集群中已安装HDFS、Yarn、Flink服务。
• 已部署和MRS集群环境网络相通的HTTP服务。
• 参考创建FlinkServer权限角色创建一个具有FlinkServer管理员权限的用户用于访问Flink WebUI，如：flinkuser。

HTTP服务作为维表

1. 使用flinkuser登录Manager界面，选择“集群 > 服务 > Flink”，在“Flink Web UI”右侧，单击链接，访问Flink的WebUI。
2. 参考创建FlinkServer作业，新建Flink SQL流作业，参考如下内容在作业开发界面进行作业开发，配置完成后启动作业。

   CREATE TABLE Customers (
     id STRING,
     id2 STRING,
     msg STRING,
     uuid STRING,
     details ROW < isActive BOOLEAN,
     nestedDetails ROW < balance STRING > >
   ) WITH (
     'connector' = 'http-lookup',
     'format' = 'json',
     'url' = 'http://http服务IP:http服务端口',
     'asyncPolling' = 'true'
   );
   CREATE TABLE Orders (
     id STRING,
     id2 STRING,
     proc_time AS PROCTIME()
   ) WITH (
     'connector' = 'datagen',
     'rows-per-second' = '1',
     'fields.id.kind' = 'sequence',
     'fields.id.start' = '1',
     'fields.id.end' = '120'
   );
   CREATE TABLE result_table(
     id STRING,
     id2 STRING,
     msg STRING,
     uuid STRING,
     isActive BOOLEAN,
     balance STRING
   ) WITH ('connector' = 'print');
   insert into
     result_table
   SELECT
     o.id,
     o.id2,
     c.msg,
     c.uuid,
     c.isActive,
     c.balance
   FROM
     Orders AS o
     JOIN Customers FOR SYSTEM_TIME AS OF o.proc_time AS c ON o.id = c.id
     AND o.id2 = c.id2;

相关表参数配置说明