Hi all, in Flink SQL I got the following behaviour: with every update in the source database (which is read by Debezium) I get first a op D followed by I (see picture). The source table is defined by an upsert-kafka connector, the underlying topic is not compacted. Is there a way to get rid of these D operations (null values)? Thanks for any advice, best regards, René