occurred while calling o2.sqlQuery.
: org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered
"ON" at line 8, column 5.
Was expecting one of:
"EXCEPT" ...
"FETCH" ...
"GROUP" ...
Maybe I miss something?
guoliubi...@foxmail.com
Hi,
I have some jobs running under flink 1.14.0. For security reason, we have to
update flink to 1.20.1.
The problem is, when I sink records to kafka, in 1.14.0, the timestamp in kafka
is the log append time. However, in 1.20.1, the timestamp in kafka is the event
time.
I have checked the sou
