Apache Flink Table 1.4:可以在 Table 上执行外部 SQL 吗?

Apache Flink Table 1.4: External SQL execution on Table possible?

是否可以在不上传 .jar 的情况下从外部查询现有 StreamTable 获取执行环境并检索 table 环境?我一直在等待 Apache Flink Table 1.4 发布,因为它具有动态(连续)table 功能。我期待其他东西,我认为可以在运行时更改 table 并修改其参数。为了进行一些实时查询,而不是在数据流之上定义(连续或仅附加)数据库视图。我知道我可以将我的 table 导出到某个数据库并使用 SQL 动态查询该数据库,但这是一种尴尬的行为。 Flink 的美妙之处在于一切都是实时的,一切都是流,那么是否可以从一些外部程序实时查询 Flink table?

不,目前不支持。

在将流式查询的结果 table 存储为可查询状态方面已经开展了一些工作。这将允许对固定键属性进行点(键查找)查询。 Flink 1.5 可能会提供此功能。

没有具体的计划来支持 SQL 对流式 SQL(或 Table API)查询生成的动态 table 查询。您必须将 table 发送到 RDBMS 并从那里查询数据。