Catalog模式创建Flink SQL作业

操作场景

在FlinkServer中创建Flink SQL作业时，默认方式需要手动配置数据连接和表结构，操作较为繁琐。通过Catalog模式，可以复用已注册的Catalog元数据（如Hive、Hudi、Iceberg等数据目录的表信息），避免重复建表操作，提高作业开发效率。

约束与限制

本章节适用于MRS 3.6.0-LTS.1及以后版本。

操作步骤

1. 访问Flink WebUI，请参考访问FlinkServer WebUI界面。
2. 单击“作业管理”进入作业管理页面。
3. 创建Flink SQL作业相关示例。
   • Catalog模式下FlinkServer对接Hive、Hudi和Iceberg服务，具体操作请参考：
     • FlinkServer对接Hive
     • FlinkServer对接Hudi
     • FlinkServer对接Iceberg
   • Catalog模式下FlinkServer对接ClickHouse、Doris、JDBC、数据仓库服务(DWS)、HBase、HDFS、Kafka、MongoDB、HTTP服务和集群连接模式下操作一致，具体操作请参考：
     • FlinkServer作业对接ClickHouse（ClickHouse Connector）
     • FlinkServer作业对接ClickHouse表（JDBC Connector）
     • FlinkServer作业对接Doris表
     • FlinkServer作业对接JDBC
     • FlinkServer作业对接数据仓库服务(DWS)
     • FlinkServer作业对接HBase表
     • FlinkServer作业对接HDFS文件系统
     • FlinkServer作业对接Kafka消息队列
     • FlinkServer作业对接MongoDB
     • FlinkServer作业对接HTTP服务