flink-cdc

flink-cdc copied to clipboard

[mysql] Don't support MySQL type 'INT UNSIGNED ZEROFILL' yet.

1

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13.3 - Flink CDC version: 2.2.1 - Database and...

yd0906

**Describe the bug(Please use English)** A clear and concise description of what the bug is. I ran a `select` sql by sql-client,the source database is MySQL ,target is sql-client print;...

vleyong

[mongodb] Support RawType conversion (#802)

1

Support `RawType` conversion of MongoDB let schema-less fields can be processed by UDF. Closed #802

Jiabao-Sun

[vitess] Add vitess cdc connector

7

This is initial implementation of Vitess CDC connector. For a fully detailed documentation of Vitess Debezium Connector , please see [Documentation](https://debezium.io/documentation/reference/connectors/vitess.html).

s-gelazevicius

Error in inserting data into es on Flink SQL CLI

1

**Describe the bug(Please use English)** Error in inserting data into es on Flink SQL CLI ``` [INFO] Submitting SQL update statement to the cluster... [ERROR] Could not execute SQL statement....

OxYGC

[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...

EMsnap

[mysql] When splitSize setting small, error

1

**Environment :** - Flink version : 1.13.5 - Flink CDC version: 2.2.0 - Database and version: 5.7.36.-log code: ``` MySqlSource mySqlSource = MySqlSource.builder() .splitSize(10) .hostname("192.168.3.111") .port(3306) .username("root") .password("root") .databaseList("flink") .tableList(new...

qq443672581

Flinkcdc 增量读取oralce ，正常输出数据一段时间后 异常关闭

3

flinkcdc增量读取oralce数据库 报错： java.lang.IllegalStateException: Retrieve schema history failed, the schema records for engine 08c6c43f-e529-439b-9546-d1056524d389 has been removed, this might because the debezium engine has been shutdown due to other errors. at...

wdzhanghao

10:08:16.249 [Canceler/Interrupts for Source: Custom Source -> Sink: Unnamed (1/1)#0 (fa21d4177bd34fe5e18fd99a4b09f437).] WARN org.apache.flink.runtime.taskmanager.Task - Task 'Source: Custom Source -> Sink: Unnamed (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:

1

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13.3 - Flink CDC version: 2.1.0 - Database and...

Angelasp

could flink cdc insert mysql just snapshot not Incremental data by binlog ？

2

I want insert mysql snapshot data on sometime by day，the data do not change frequent。

linmingze