[jira] [Commented] (FLINK-39369) ChangelogNormalize Operator In WAL Image Mode with Fluss

[Xuyang Zhong (Jira)]

    [ 
https://issues.apache.org/jira/browse/FLINK-39369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18070476#comment-18070476
 ] 

Xuyang Zhong commented on FLINK-39369:
--------------------------------------

[~ipolyzos] Let me take a look 🤔

> 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
>            Priority: Minor
>         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)