Re: Possible bug when converting table to upsert changelog stream

Hi, Charles It is not a bug, this is because the primary keys provided by sink are not exactly match input changeLogUpsertKeys, so fallback to before and after mode, you can see [1] for more detail. [1]

Possible bug when converting table to upsert changelog stream

Hi everyone, I noticed some unexpected behavior with Upsert changelogs in Flink 1.17.1 and I wanted to post here to see if anyone has encountered a similar issue. I’m running a Flink application which performs SQL queries using the Flink SQL and Table APIs, then I convert the resulting table to a