设置Flink应用程序与多个不同的SQL查询（聚合）

Question

我需要使用来自同一来源的不同列聚合构建管道，例如，一个按userId，另一个按productId，等等。我还希望有不同的颗粒度聚合，例如按小时、每天。每个聚合将有不同的接收器，例如不同的nosql表。

使用表API构建SQL查询似乎很简单。但我想减少管理太多Flink应用程序的操作开销。所以我想把所有不同的SQL查询放在一个pyflink应用程序中。

这是我第一次创建Flink应用程序。所以我不确定这是否可行。我特别想知道：

• 阅读Flink doc，我看到了应用与工作的概念。所以我很好奇，是否每个SQL聚合查询都是一个Flink作业
• 是否会因为一个Flink应用程序中的查询太多而导致整体性能下降
• 由于查询共享同一个源（来自kinesis），每个查询都会获得源的副本吗。基本上，我想确保每个sql聚合查询都会处理每个事件

谢谢

Answer 1

如果使用语句集，则可以将多个查询放入一个作业中：https://docs.ververica.com/user_guide/sql_development/sql_scripts.html