shouweikun commented on pull request #18199:
URL: https://github.com/apache/flink/pull/18199#issuecomment-1056468031
@jjrrzxc Hi, I'm afraid that this pr can not work on your problem.
Actually `StreamPhysicalWindowAggregate` only does consume **Insert-only**
records for now.
Meanwhile `upsert-kafka` has no choice but to produce changelog stream.
So maybe you can choose regular aggregate instead of TVF window agg to solve
your problem.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
