StingPeng

[mysql] expose update_before field in the metadata through flink sql

3

**Is your feature request related to a problem? Please describe.** see https://nightlies.apache.org/flink/flink-docs-master/zh/docs/connectors/table/formats/canal/ in canal json user would want OLD field to know the update before data before UPDATE record **Describe...

support read all mysql database data with no schema restrict

1

**Is your feature request related to a problem? Please describe.** The thing is sometime user want to export all data from database with diffrent schema to kafka with canal json...

[mysql] expose meta_ts field in the metadata through flink sql

5

[mysql] expose meta_ts field in the metadata through flink sql #1141

pls see https://github.com/ververica/flink-cdc-connectors/issues/1555

**Environment :** - Flink version : 1.13 - Flink CDC version: 2.3-SNAPSHOT - Database and version: oracle-xe-11g-r2-cdc:0.1 **To Reproduce** Steps to reproduce the behavior: 1. The test data : 2....

- Fixes #6174 ### Motivation [INLONG-6174][Sort] Mysql connector support meta data with debezium format ### Modifications [INLONG-6174][Sort] Mysql connector support meta data with debezium format ### Verifying this change run...

- Fixes #6152 ### Motivation Add Row kind validator to filter different kinds of rowData Supports four row kinds to be flitered : INSERT UPDATE_BEFORE UPDATE_AFTER DELETE. ### Modifications Add...

### Description [Feature] Mysql connector support meta data with debezium format ### Use case [Feature] Mysql connector support meta data with debezium format ### Are you willing to submit PR?...

### Description [Feature] Mysql connector support filtering kinds of row data ### Use case [Feature] Mysql connector support filtering kinds of row data ### Are you willing to submit PR?...

### Description [Feature] improve agent InlongDatabaseHistory implementation ### Use case [Feature] improve agent InlongDatabaseHistory implementation ### Are you willing to submit PR? - [X] Yes, I am willing to submit...