Hi! Window join in Flink SQL is supported since Flink 1.14, see document [1].
[1] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/sql/queries/window-join/ Lu Niu <qqib...@gmail.com> 于2021年10月29日周五 上午2:12写道： > Hi, Flink users > > How to express multiple stream window join in flink sql? in datastream > api, that's > > stream.join(otherStream) > .where(<KeySelector>) > .equalTo(<KeySelector>) > .window(<WindowAssigner>) > .apply(<JoinFunction>) > > ( > https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/operators/joining/ > ) > > For example, in flinksql, how to join two streams in tumbling window and > evaluate a udf joinFunction? > > Best > Lu >
