用flink区间连接清理状态行为

Question

我正在读

https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sql/queries/joins/#interval-joins，

它有以下例子：

SELECT *
FROM Orders o, Shipments s
WHERE o.id = s.order_id
AND o.order_time BETWEEN s.ship_time - INTERVAL '4' HOUR AND s.ship_time

我有两个问题：

1. 如果o.order_time和s.ship_time是正常的时间列，而不是事件时间属性，那么所有的状态都会保存在Flink中，就像普通的规则内部连接那样？这样，也许大尺寸的状态就会保持在Flink

中。

1. 如果o.order_time和s.ship_time是事件时间属性，那么flink将依靠水印进行状态清理吗？这样小规模的状态将保持在Flink

中。

Answer 1

是的，没错。Flink SQL之所以有时间属性的概念，是因为合适的流查询可以自动清除它们的状态，而间隔连接就是这样一个查询的例子。在版本化的表上，时间窗口和时态连接也以类似的方式工作。