Giannis Polyzos created FLINK-39369:
---------------------------------------
Summary: ChangelogNormalize Operator In WAL Image Mode with Fluss
Key: FLINK-39369
URL: https://issues.apache.org/jira/browse/FLINK-39369
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.20.0
Reporter: Giannis Polyzos
Attachments: Screenshot 2026-03-31 at 6.09.11 PM.png
Flink 1.20 and Fluss 0.9
When using `'table.changelog.image' = 'WAL'` Fluss skips the `UPDATE_BEFORE`
on the WAL.
However during streaming reads, because `UPDATE_BEFORE` is not generated, this
makes Flink to introduce the `ChangelogNormalize` operator which is expensive
and unwanted.
I tried to disable the operator with `table.exec.sink.upsert-materialize=NONE`
however seems like its not taking effect
(see attached image)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
