Lee SeungMin created FLINK-34689: ------------------------------------ Summary: check binlog_row_value_optoins Key: FLINK-34689 URL: https://issues.apache.org/jira/browse/FLINK-34689 Project: Flink Issue Type: Improvement Components: Flink CDC Reporter: Lee SeungMin Attachments: image-2024-03-15-12-56-49-344.png
When {{binlog_row_value_optoins}} is set to {{{}PARTIAL_JSON{}}}, the update operator remains as {{{}Update_rows_partial{}}}. Flink CDC does not parse this event because {{Update_row_partial}} binlog event is mapped to {{PARTIAL_UPDATE_ROWS_EVENT}} and Flink CDC do not handle that event type Example of Update_row_partial (when {{binlog_row_value_optoins}} = {{PARTIAL_JSON)}} !image-2024-03-15-12-56-49-344.png|width=1015,height=30! So, we have to check {{binlog_row_value_optoins}} before starting. Cretae PR: [[MySQL][Feature] check binlog_row_value_optoins by SML0127 · Pull Request #3148 · apache/flink-cdc (github.com)|https://github.com/apache/flink-cdc/pull/3148] -- This message was sent by Atlassian Jira (v8.20.10#820010)