Your query
SELECT STREAM a.foo, b.bar
FROM a JOIN a.id = b.id
GROUP BY TUMBLE(a. rowtime, INTERVAL '1' MINUTE)
won't work because there is no constraint on b.rowtime. The system would
literally have to wait forever before it could move on from a, or output a
total. Let’s try this:
SELE
Hi,
I wonder what would be the best way to express joining two windowed streams
in SQL?
A even simpler use case will be joining two streams within the same window
(see
https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html).
I'm looking at something like
SELECT a.foo
