[Bug] Exception thrown when processing the DELETE cdc record in canal-json with the paimon-action-jar
- Dominant language
- Java
- Stars
- 3.4k
- Forks
- 1.4k
- Avg merge
- 1d 11h
- Merged PRs (30d)
- 396
Description
### Search before asking
- [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar.
### Paimon version
0.9 +
### Compute Engine
flink
### Minimal reproduce step
1. Flink CDC collect mysql data to kafka, including delete record.
2. Use paimon-flink-action to kafka_sync_database
### What doesn't meet your expectations?
Exception thrown as ”Expected node 'data' to be of type ArrayNode but was NullNode.“
### Anything else?
_No response_
### Are you willing to submit a PR?
- [X] I'm willing to submit a PR!
Contributor guide
No contributing guide indexed for this repository
Research direction
Reproduce the failure with Flink CDC MySQL delete records flowing through Kafka into paimon-flink-action's kafka_sync_database, focusing on the canal-json handling of the delete record. Confirm the expected behavior for the null 'data' node and verify that the DELETE record is processed without the reported exception.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, kafka, mysql
- Domain
- data-engineering, databases, stream-processing
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100