You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/27 07:26:00 UTC
[jira] [Assigned] (FLINK-34689) check binlog_row_value_optoins
[ https://issues.apache.org/jira/browse/FLINK-34689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Qingsheng Ren reassigned FLINK-34689:
-------------------------------------
Assignee: Lee SeungMin
> 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
> Assignee: Lee SeungMin
> Priority: Major
> Labels: pull-request-available
> 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)