Hi Joe,
>
> caused by: org.apache.calcite.runtime.CalciteContextException: From line
> 1, column 139 to line 1, column 181: Cannot apply '$TUMBLE' to arguments of
> type '$TUMBLE(, )'. Supported form(s):
> '$TUMBLE(, )'
The first parameter of Group Window Function [1] must be a field with time
att
Hi all,
I am on Flink 1.12.3.
So here’s the scenario: I have a Kafka topic as a source, where each record repsents a change to an append only audit log. The kafka record has the following fields:
id (unique identifier for that audit log entry)
operation id (is shared across
