[Bug] Flink SQL task Insert op 'd' data on lake storage model NullPointerException

[1272870698]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

Fluss table properties :
WITH ( 'bootstrap.servers' = '10.255.48.33:9123', 'bucket.key' = 'sale_ordr_doc,goods_code,line_item,lotn', 'bucket.num' = '4', 'table.datalake.enabled' = 'true', 'table.auto-partition.enabled' = 'true', 'table.auto-partition.time-unit' = 'day' )

Writing data in debezium-json format in Kafka to Fluss through Flink SQL, a NullPointerException occurred when encountering delete data with op ='d':

Solution

No response

Anything else?

Tracking found that setting the row parameter to null when processing Delete data caused this error:
The specific code is shown in the figure

This led to an error in obtaining bucket related information in figure 2

Willingness to contribute

• I'm willing to submit a PR!