The correct Flinksql lastValueWithRetractAggFunction LongLastValueWithRetractAggFunction

Error:

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: No matching accumulate method found for AggregateFunction ‘org.apache.flink.table.planner.functions.aggfunctions.LastValueWithRetractAggFunction.LongLastValueWithRetractAggFuncti on’with parameters ‘(java.lang.Long, java.lang.Integer)’.

The code of investigation and discovery is:

last_value(coalesce(c1),-99) as c1

You need to modify it to:

last_value(coalesce(c1,-99)) as c1

Is the “) “position is wrong!!

Flinksql

end