从 Java/Scala 程序中的数据流创建 SQL Table 并从 SQL 客户端 CLI - Apache Flink 查询它

Create SQL Table from a DataStream in a Java/Scala program and query it from SQL Client CLI - Apache Flink

是否可以使用 Flink SQL 客户端 CLI 与 table 交互,其中 table 是在集群中的 Scala/Java 程序 运行 中创建的?

不,这不可能。

您可以将 Scala/Java 程序的 DataStream 放入消息队列或事件日志(如 Apache Kafka 或 Apache Pulsar)中的主题,并在 CLI 客户端中将该主题注册为 table。

table注册后,可以在客户端用SQL查询