[Bug] When the paimon-flink-cdc module processes Kafka messages formatted in maxwell-json, if it encounters events lacking the "data" field, such as "table-alter", the program immediately throws an error and enters an unrecoverable state. #5092
Labels
bug
Something isn't working
Search before asking
Paimon version
9d2a460
Compute Engine
flink 1.17
Minimal reproduce step
1.Establish a connection with the MySQL database, Maxwell collector, Kafka, and the paimon-flink-cdc program.
2.Initiate table-level modifications on MySQL tables, specifically table-alter events, such as ALTER TABLE xxx AUTO_INCREMENT = 2300.
3.The paimon-flink-cdc will throw an error message: "invalid maxwell-json format: missing 'data' field."
What doesn't meet your expectations?
The program encountered an error and cannot be recovered. It is expected to prevent such errors.
Anything else?
No response
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: