使用FileCatalogStore对catalog进行持久化

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

本章节提供使用FileCatalogStore的操作入门指导。

1. 已安装集群客户端，例如安装目录为“/opt/hadoopclient”。
2. 在Flink客户端配置文件“客户端安装目录/Flink/flink/conf/flink-conf.yaml”中新增如下配置：

   table.catalog-store.kind: file  // 设置catalog存储类型
   table.catalog-store.file.path: hdfs:///flink/catalogStore  // 设置catalog存储的文件路径

3. 以客户端安装用户，登录安装客户端的节点。
4. 参考使用SQL•Client启动一个SQL Client。
5. 在SQL client中执行SQL语句新增一个MySQL catalog，例如：

   CREATE CATALOG `jdbcCatalog` WITH (
    'type'='jdbc', 
    'default-database'='flink', 
    'username'='xxx', 
    'password'='xxx', 
    'base-url'='jdbc:mysql://mysql服务ip:mysql服务端口'
   );

6. 用HDFS客户端查看持久化到目录的catalog配置文件。

   

7. 退出SQL Client重新启动后，还能查到之前创建的catalog