当使用tableApi连接多个表时，flink创建了什么状态/s？

Question

我有多个要加入的流(A到B，B到C，C到D.)创建一个Z

当使用表api和连接3个表时

select * from A inner join B on a.pk_id = b.fk_id inner join C on b.pk_id = c.fk_id

底层状态/s是什么样子的？

如果键是并行运行的，则键与每个源不同。Flink对数据进行重组吗？

Answer 1

您可以通过查看web中的作业图来解决这个问题。到处都是杂乱，到处都是哈希连接。

这些信息也包含在EXPLAIN <query>的输出中，但这更难理解(查找Exchange)。