Skip to content

[FLINK-39684] Fix PaimonWriterHelper NullPointerException when handling REPLACE events#4398

Merged
yuxiqian merged 1 commit into
apache:masterfrom
yuxiqian:FLINK-39684
May 18, 2026
Merged

[FLINK-39684] Fix PaimonWriterHelper NullPointerException when handling REPLACE events#4398
yuxiqian merged 1 commit into
apache:masterfrom
yuxiqian:FLINK-39684

Conversation

@yuxiqian
Copy link
Copy Markdown
Member

@yuxiqian yuxiqian commented May 15, 2026 •
edited
Loading

This closes FLINK-39684.

Pipeline YAML ReplaceEvent carries after() payload only, but PaimonWriterHelper attempts to access its before() field, causing the following exception:

java.lang.NullPointerException
	at org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriterHelper.convertRecordDataToGenericRow(PaimonWriterHelper.java:307)
	at org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriterHelper.convertEventToFullGenericRows(PaimonWriterHelper.java:257)

lvyanquan
lvyanquan approved these changes May 18, 2026
View reviewed changes
Copy link
Copy Markdown
Contributor

@lvyanquan lvyanquan left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM.

@yuxiqian yuxiqian merged commit a24b34f into apache:master May 18, 2026
53 of 56 checks passed
@yuxiqian yuxiqian deleted the FLINK-39684 branch May 18, 2026 02:39
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@lvyanquan lvyanquan lvyanquan approved these changes

Assignees

No one assigned

Labels

approved paimon-pipeline-connector reviewed

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@yuxiqian @lvyanquan