Hi Yuval,
having a locally reproducible result would be great. Also more
information about the used data types. Because this could be a
serializer issue that messes up the binary format.
Regards,
Timo
On 27.07.21 07:37, Yuval Itzchakov wrote:
Hi Jing,
Yes, FIRST is a UDAF.
I've been tryi
Hi Jing,
Yes, FIRST is a UDAF.
I've been trying to reproduce this locally without success so far.
The query itself has more fields and aggregates. Once I can reproduce this
locally I'll try to narrow down the problematic field and share more
information.
On Tue, Jul 27, 2021, 05:17 JING ZHANG
Hi Yuval,
I run a similar SQL (without `FIRST` aggregate function), there is nothing
wrong.
`FIRST` is a custom aggregate function? Would you please check if there is
a drawback in `FIRST`? Whether the query could run without `FIRST`?
Best,
JING ZHANG
Yuval Itzchakov 于2021年7月27日周二 上午12:29写道：
>
Hi,
*Setup:*
1 JM,
1 TM,
Flink 1.13.1
RocksDBStateBackend.
I have a query with the rough sketch of the following:
SELECT CAST(TUMBLE_START(event_time, INTERVAL '2' MINUTE) AS TIMESTAMP)
START_TIME
CAST(TUMBLE_END(event_time, INTERVAL '2' MINUTE) AS
TIMESTAMP) END_TIME
