The reference docs and javadocs both state that my...
# troubleshootinga
Adam Augusta
04/07/2023, 7:56 PMThe reference docs and javadocs both state that my TableAggregateFunction needs emitValue or emitUpdateWithRetract.
But if I implement the latter and not the former, I get a validation error.
If I implement both, only emitValue is used.
Poking around the Flink source code, ImperativeAggCodeGen seems agnostic to emitUpdateWithRetract. Alarmingly, there’s not a single Flink test that uses a class with a emitUpdateWithRetract method. Can anyone shed light on my confusion?
Adam Augusta
04/10/2023, 4:03 PMhttps://lists.apache.org/thread/ynzg3x1f3377p42kkcwt60xyt9o8d8mr
For anyone who was curious, this well-documented feature was silently removed in 1.14.
I wonder if there’s a contemporary way to achieve the same result.
m
Martijn Visser
04/11/2023, 9:33 AMthis well-documented feature was silently removed in 1.14.Minor nit: it was not silently removed. The removal of the Blink planner is in the Flink 1.14 release notes, see https://nightlies.apache.org/flink/flink-docs-release-1.16/release-notes/flink-1.14/