Flink SQL Client会话关闭后创建的表消失，求排查解决

你创建的表是会话级临时表，默认情况下Flink SQL Client使用的是内存Catalog（GenericInMemoryCatalog），这种Catalog的元数据仅保存在当前会话的内存中，关闭会话后元数据就会被销毁，所以重启会话后看不到之前创建的表。

要让表元数据持久化、跨会话可见，需要配置持久化Catalog，比如Hive Catalog或JDBC Catalog，以下是具体操作：

方法1：配置Hive Catalog（推荐） #

1. 修改flink-conf.yaml，添加Hive Catalog相关配置：

# 配置默认Catalog
catalogs:
  - name: hive_catalog
    type: hive
    hive-conf-dir: /path/to/hive/conf
    default-database: default

2. 重启Flink集群，确保配置生效。
3. 进入SQL Client后，切换到Hive Catalog：

USE CATALOG hive_catalog;

4. 之后创建的表就会保存在Hive Catalog中，重启会话后依然可见。

方法2：使用JDBC Catalog #

如果没有Hive环境，可以用JDBC Catalog将元数据存储在关系型数据库（比如MySQL）中：

1. 在flink-conf.yaml中添加JDBC Catalog配置：

catalogs:
  - name: jdbc_catalog
    type: jdbc
    default-database: flink_metadata
    username: root
    password: your_password
    base-url: jdbc:mysql://mysql-host:3306/

2. 重启集群后，在SQL Client中切换Catalog：

USE CATALOG jdbc_catalog;

3. 创建表后，元数据会保存在MySQL中，跨会话可见。

方法3：会话内创建持久化Catalog（临时生效） #

如果不想修改集群配置，可以在SQL Client会话内创建Catalog：

-- 创建Hive Catalog
CREATE CATALOG hive_catalog WITH (
    'type' = 'hive',
    'hive-conf-dir' = '/path/to/hive/conf'
);

-- 切换到该Catalog
USE CATALOG hive_catalog;

这种方式下，每次启动SQL Client都需要重新创建并切换Catalog，适合临时测试场景。

内容的提问来源于stack exchange，提问作者taymedee