Hi Dawid,
I simplified my sql, the original sql is more complex and have a unnest
select like:
*SELECT
a.account,
(SUM(a.value) + SUM(b.value)) as result,
TUMBLE_START(a.producer_timestamp, INTERVAL '3' MINUTE)
FROM
(SELECT
account,
Hi,
Could you check your query again? I could not reproduce your issue on
latest master. I had to adjust your query slightly though:
SELECT
a.account,
(SUM(a.`value`) + SUM(b.`value`)) as `result`,
TUMBLE_START(a.producer_timestamp, INTERVAL '3' MINUTE)
FROM
Looks like a bug to me, could you fire an issue for this?
Best,
Kurt
On Thu, Jan 2, 2020 at 9:06 PM jeremyji <18868129...@163.com> wrote:
> Two stream as table1, table2. We know that group with regular join won't
> work
> so we have to use time-windowed join. So here is my flink sql looks
Two stream as table1, table2. We know that group with regular join won't work
so we have to use time-windowed join. So here is my flink sql looks like:
*SELECT
a.account account,
SUM(a.value) + SUM(b.value),
UNIX_TIMESTAMP(TUMBLE_START(a.producer_timestamp, INTERVAL '3'
