列出 Flink SQL 作业中的所有 Sources 和 Sinks答案

【问题标题】：List all Sources and Sinks in a Flink SQL job列出 Flink SQL 作业中的所有 Sources 和 Sinks
【发布时间】：2020-11-11 01:18:34
【问题描述】：

我正在围绕 Flink SQL 构建一种包装器。我用StreamTableEnvironment.sqlUpdate 用一堆用户指定的SQL 语句构造了一个作业。有些是INSERTs，有些是CREATEs。我也做了一些sqlQuerys。

在调用StreamExecutionEnvironment.execute 之前，我想列出用户创建的所有源和接收器。

有没有简单/官方的方法可以做到，还是我需要去StreamExecutionEnvironment.getStreamGraph().getJobGraph().getVerticesSortedTopologicallyFromSources()探索？

最好的问候

编辑：我需要表名和相关架构。

【问题讨论】：

【解决方案1】：

没关系，您可以使用StreamTableEnvironment.listTables() 查询StreamTableEnvironment 中的表，然后执行StreamTableEnvironment.from(tableName).getSchema()

【讨论】：