news 2026/6/9 23:18:14

Flink SQL「SHOW / SHOW CREATE」元数据巡检、DDL 复刻与排障速查（含 Java 示例）

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Flink SQL「SHOW / SHOW CREATE」元数据巡检、DDL 复刻与排障速查（含 Java 示例）

1. SHOW 与 SHOW CREATE 的定位

1.1 SHOW：列出“某个父级下的对象”

SHOW用于列出其对应父对象下的对象清单，例如：

  • catalogs、databases
  • tables、views、materialized tables
  • columns、functions、modules
  • partitions、procedures
  • （CLI/Gateway 侧）jars、jobs
  • models

1.2 SHOW CREATE：打印“可复刻的 DDL”

SHOW CREATE用来打印创建某个对象的 DDL，目前（在你给的内容里）：

  • SHOW CREATE可用于 table 和 view
  • 同时文档还给出了SHOW CREATE MODEL（模型 DDL 打印），用于复刻模型

额外注意：SHOW CREATE TABLE当前仅支持 Flink SQL DDL 创建的表。

2. Flink SQL 当前支持的 SHOW 清单（官方列表）

  • SHOW CATALOGS
  • SHOW CURRENT CATALOG
  • SHOW CREATE CATALOG
  • SHOW DATABASES
  • SHOW CURRENT DATABASE
  • SHOW TABLES
  • SHOW CREATE TABLE
  • SHOW COLUMNS
  • SHOW PARTITIONS
  • SHOW PROCEDURES
  • SHOW VIEWS
  • SHOW CREATE VIEW
  • SHOW MATERIALIZED TABLES
  • SHOW CREATE MATERIALIZED TABLE
  • SHOW FUNCTIONS
  • SHOW MODULES
  • SHOW JARS
  • SHOW JOBS
  • SHOW MODELS

3. Java 里怎么执行 SHOW？（TableEnvironment.executeSql）

在 Java 中，SHOW语句通过TableEnvironment.executeSql()执行：

  • 成功：返回可打印的结果对象（TableResult）
  • 失败：抛异常

示例（与你提供的内容一致，略去 connector 细节）：

StreamExecutionEnvironmentenv=StreamExecutionEnvironment.getExecutionEnvironment();StreamTableEnvironmenttEnv=StreamTableEnvironment.create(env);// show catalogstEnv.executeSql("SHOW CATALOGS").print();// show current catalogtEnv.executeSql("SHOW CURRENT CATALOG").print();// create a catalogtEnv.executeSql("CREATE CATALOG cat2 WITH (...)");// show create catalogtEnv.executeSql("SHOW CREATE CATALOG cat2").print();// show databasestEnv.executeSql("SHOW DATABASES").print();// show current databasetEnv.executeSql("SHOW CURRENT DATABASE").print();// create a tabletEnv.executeSql("CREATE TABLE my_table (...) WITH (...)");// show tablestEnv.executeSql("SHOW TABLES").print();// show create tabletEnv.executeSql("SHOW CREATE TABLE my_table").print();// show columns with LIKE filtertEnv.executeSql("SHOW COLUMNS FROM my_table LIKE '%f%'").print();// create a viewtEnv.executeSql("CREATE VIEW my_view AS SELECT * FROM my_table");// show viewstEnv.executeSql("SHOW VIEWS").print();// show create viewtEnv.executeSql("SHOW CREATE VIEW my_view").print();// show functionstEnv.executeSql("SHOW FUNCTIONS").print();// show user functionstEnv.executeSql("SHOW USER FUNCTIONS").print();// show modulestEnv.executeSql("SHOW MODULES").print();// show full modulestEnv.executeSql("SHOW FULL MODULES").print();

4. Catalog / Database：先找“你在哪里”，再找“你有什么”

4.1 SHOW CATALOGS：列出所有 catalog（支持 LIKE/ILIKE/NOT）

SHOWCATALOGS[[NOT](LIKE|ILIKE)<sql_like_pattern>]

  • LIKE：大小写敏感

  • ILIKE：大小写不敏感

  • pattern 规则沿用 MySQL：

    • %任意长度（可为 0）
    • _单字符
    • \%、\_表示字面量

例子：

SHOWCATALOGS;SHOWCATALOGSLIKE'%log1';SHOWCATALOGS ILIKE'%LOG1';

4.2 SHOW CURRENT CATALOG：当前 catalog 是谁？

SHOWCURRENTCATALOG;

4.3 SHOW CREATE CATALOG：打印 catalog 的创建语句

SHOWCREATECATALOG catalog_name;

输出包含 catalog 名称与属性配置，适合做“环境对照/复刻”。

4.4 SHOW DATABASES：列出某个 catalog 下的库（可选）

SHOWDATABASES[(FROM|IN)catalog_name][[NOT](LIKE|ILIKE)<pattern>]

4.5 SHOW CURRENT DATABASE：当前 database 是谁？

SHOWCURRENTDATABASE;

5. Table / View：列清单 + 复刻 DDL（最常用）

5.1 SHOW TABLES：列出表（可指定库，可 LIKE/NOT LIKE）

SHOWTABLES[(FROM|IN)[catalog_name.]database_name][[NOT]LIKE<pattern>]

例子（官方示例风格）：

SHOWTABLESFROMdb1;SHOWTABLESFROMcatalog1.db1;SHOWTABLESFROMdb1LIKE'%n';SHOWTABLESFROMdb1NOTLIKE'%n';SHOWTABLES;

5.2 SHOW CREATE TABLE：一键打印建表 DDL

SHOWCREATETABLE[[catalog_name.]db_name.]table_name;

输出包含：

  • 表名（通常是全限定名）
  • 字段名、类型
  • 约束（如 PK NOT ENFORCED）
  • 注释
  • watermark、计算列等
  • WITH 配置（connector/options）

注意：当前只支持 Flink SQL DDL 创建的表。

5.3 SHOW VIEWS / SHOW CREATE VIEW：视图同理

SHOWVIEWS[(FROM|IN)[catalog_name.]database_name][[NOT]LIKE<pattern>];SHOWCREATEVIEW[catalog_name.][db_name.]view_name;

6. 列、分区与过程：排障时“特别顶用”的三件套

6.1 SHOW COLUMNS：列结构速查（支持 LIKE/NOT LIKE）

SHOWCOLUMNS(FROM|IN)[[catalog_name.]database.]table_name[[NOT]LIKE<pattern>];

典型用途：

  • 快速确认字段名、类型、是否可为空
  • 判断是否存在 watermark / proctime / computed column
  • 排查“写入字段不匹配”“字段名拼错”“类型不兼容”等问题

6.2 SHOW PARTITIONS：分区表排查神器

SHOWPARTITIONS[[catalog_name.]database.]table_name[PARTITION(k1=v1,k2=v2,...)];

典型用途：

  • “我明明写了数据，为什么查不到？”——先看分区是否写进了你预期的分区
  • “我过滤条件生效了吗？”——对照分区列表比猜更靠谱

6.3 SHOW PROCEDURES：列出过程（可过滤）

SHOWPROCEDURES[(FROM|IN)[catalog_name.]database_name][[NOT](LIKE|ILIKE)<pattern>];

7. Functions / Modules：函数找不到、解析怪？先看它俩

7.1 SHOW FUNCTIONS（系统函数 + UDF），SHOW USER FUNCTIONS（仅 UDF）

SHOW[USER]FUNCTIONS[(FROM|IN)[catalog_name.]database_name][[NOT](LIKE|ILIKE)<pattern>];

7.2 SHOW MODULES / SHOW FULL MODULES：看模块启用状态与解析顺序

SHOW[FULL]MODULES;
  • SHOW MODULES：仅显示“启用的模块”和解析顺序
  • SHOW FULL MODULES：显示“已加载模块 + used(true/false) 状态 + 解析顺序”

很多“同名函数冲突/突然不可用”的根因，就是模块启用状态或解析顺序变化。

8. SQL CLI / SQL Gateway 限定：SHOW JARS、SHOW JOBS

SHOWJARS;SHOWJOBS;

注意（官方强调）：

  • 目前SHOW JARS/SHOW JOBS只在 SQL CLI 或 SQL Gateway 生效
  • 在纯 Java TableEnvironment 场景下不一定可用（取决于你接入方式）

9. 模型：SHOW MODELS 与 SHOW CREATE MODEL

SHOWMODELS[(FROM|IN)[catalog_name.]database_name][[NOT](LIKE|ILIKE)<pattern>];SHOWCREATEMODEL[catalog_name.][db_name.]model_name;

SHOW CREATE MODEL的输出包含：

  • model 名称
  • 输入/输出 schema
  • model options 与其它配置

适合：理解既有模型结构、跨库复刻模型。

10. 一套“拿来就用”的排障顺序（强烈推荐）

当你遇到：表找不到 / 函数解析不对 / DDL 不清楚 / 分区数据缺失——按这个顺序走：

1）确认上下文

SHOWCURRENTCATALOG;SHOWCURRENTDATABASE;

2）确认对象是否存在

SHOWTABLES;SHOWVIEWS;SHOWFUNCTIONS;

3）对象太多就过滤

SHOWTABLESLIKE'%order%';SHOWFUNCTIONS ILIKE'%sha%';

4）需要复刻/核对结构

SHOWCREATETABLExxx;SHOWCOLUMNSFROMxxx;

5）分区问题

SHOWPARTITIONS xxx;

6）函数冲突/不可用

SHOWFULLMODULES;

SHOW/SHOW CREATE 在 Flink SQL 里不只是“看一眼”的命令，而是一套完整的元数据自检与复刻工具链：写 SQL 前先确认上下文，出问题先 SHOW 再猜，迁移环境直接 SHOW CREATE 复制 DDL，效率会高一大截。

版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！
网站建设 2026/6/10 13:46:08

FSearch终极指南：Linux文件搜索效率倍增技巧

还在为Linux系统中繁杂的文件查找而头疼吗&#xff1f;FSearch快速文件搜索工具正是您需要的解决方案。这款基于GTK3的轻量级工具&#xff0c;让您在Linux桌面上享受前所未有的文件搜索效率提升。本文将带您从零开始&#xff0c;全面掌握FSearch的安装配置、使用技巧和进阶优化…

作者头像 李华
网站建设 2026/6/10 5:43:52

X-AnyLabeling零基础入门到精通：全平台高效数据标注实战指南

X-AnyLabeling零基础入门到精通&#xff1a;全平台高效数据标注实战指南 【免费下载链接】X-AnyLabeling Effortless data labeling with AI support from Segment Anything and other awesome models. 项目地址: https://gitcode.com/gh_mirrors/xa/X-AnyLabeling 在计…

作者头像 李华
网站建设 2026/6/9 16:09:53

从“十五五”规划建议看智慧工厂重点发展方向

随着“十五五”规划建议的发布&#xff0c;我国制造业迎来了新的发展机遇与挑战。规划明确提出&#xff0c;要坚持以智能化、绿色化、融合化方向&#xff0c;加快建设制造强国&#xff0c;保持制造业合理比重&#xff0c;构建以先进制造业为骨干的现代化产业体系。智慧工厂需通…

作者头像 李华
网站建设 2026/6/10 6:37:58

结合 AI 视觉：使用 OCR 识别企业微信聊天记录中的图片信息

一、 引言&#xff08;Introduction&#xff09; 业务背景&#xff1a; 许多关键业务信息&#xff08;如&#xff1a;客户发送的转账截图、入群申请说明、包含联系方式的海报&#xff09;都以图片形式存在于聊天记录中。 技术痛点&#xff1a; 传统的 UI 自动化只能获取“这是…

作者头像 李华
网站建设 2026/6/10 13:44:56

从零开始：Obsidian数据导入工具的完全掌握指南

从零开始&#xff1a;Obsidian数据导入工具的完全掌握指南 【免费下载链接】obsidian-importer Obsidian Importer lets you import notes from other apps and file formats into your Obsidian vault. 项目地址: https://gitcode.com/gh_mirrors/ob/obsidian-importer …

作者头像 李华
网站建设 2026/6/10 13:45:10

7、数据清洗与转换：从文本到结构化数据

数据清洗与转换：从文本到结构化数据 在数据处理过程中，清洗和转换数据是至关重要的步骤。本文将介绍一些常见的数据处理操作，包括过滤行、提取值、替换和删除值，以及处理不同格式的数据，如 CSV、HTML/XML 和 JSON。 过滤行 过滤行是数据清洗的第一步，它可以根据行的位…

作者头像 李华