flink-cdc

flink-cdc copied to clipboard

Failed to deserialize data of EventHeaderV4

1

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

l1183479157

Oracle CDC startupoptions.initial (), does not perform increments after the full quantity is executed.

5

**Describe the bug(Please use English)** Oracle CDC startupoptions.initial (), does not perform increments after the full quantity is executed. **Environment :** - Flink version : 1.14.2 - Flink CDC version:...

hezhenghongmail

Flink SQL Source Mysql To Sink PoshtgreSQL NoClassDefFoundError: org/apache/flink/util/function/SerializableFunction

1

Flink Version 1.14 jar file: flink-connector-jdbc_2.12-1.14.4 flink-sql-connector-mysql-cdc-2.2.1 postgresql-42.2.20 mysql-connector-java-8.0.25 Source SQL: CREATE TABLE products_mysql ( id INT, name STRING, description STRING, PRIMARY KEY (id) NOT ENFORCED ) WITH ( 'connector'...

have1568

[sqlserver] [wiki] Add FAQ for sqlserver connector.

1

Add sqlserver schema evolution in wiki FAQ page.

GOODBOY008

oracle-connector实时读取只读备库的问题

8

因为目前的现状是公司只提供一个oracle只读备库的环境用于数据同步，因为cdc在部署的时候需要在对接的oracle库下创建相关信息表，故无法执行，麻烦请问，对于这种情况，如何使用oracle-connector完成数据同步？

wangdabin1216

[MySql] not to throw an exception when bin log format changed from row to others to stop job from endless restarting.

2

issue: flink job get restarted and stuck at an exception when bin log format changed from row to others exception : Caused by: io.debezium.DebeziumException: Received DML versions: flink 1.13 cdc...

Fisher666

Is it so hard to support Flink1.14.*

2

**Describe the bug(Please use English)** Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.guava18.com.google.common.util.concurrent.ThreadFactoryBuilder **Environment :** - Flink version : 1.14.5 - Flink CDC version: 2.2.1 unsupported documents can be deleted？ 

future94

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

Matrix42

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

EMsnap

[Feature] debezium version can upgrade to 1.9, the version 1.6.4Final has some Bug

4

**Is your feature request related to a problem? Please describe.** i make sure the issue https://github.com/ververica/flink-cdc-connectors/issues/1279 is relation to debezium 1.6.4Final version's Bug **Describe the solution you'd like** I think...

youyangkou