authuir commented on a change in pull request #12420:
URL: https://github.com/apache/flink/pull/12420#discussion_r444587139
##########
File path: docs/dev/table/streaming/joins.zh.md
##########
@@ -63,18 +61,17 @@ WHERE o.id = s.orderId AND
o.ordertime BETWEEN s.shiptime - INTERVAL '4' HOUR AND s.shiptime
{% endhighlight %}
-Compared to a regular join operation, this kind of join only supports
append-only tables with time attributes. Since time attributes are
quasi-monotonic increasing, Flink can remove old values from its state without
affecting the correctness of the result.
+与常规 Join 操作相比,时间窗口 Join 只支持带有时间属性的递增表。由于时间属性是单调递增的,Flink
可以从状态中移除过期的数据,而不会影响结果的正确性。
Review comment:
Fixed
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]