flink-cdc

flink-cdc copied to clipboard

TiDB cdc demo improve

2

**Describe the bug(Please use English)** TiDB cdc demo run failed. **Environment :** - Flink version : 1.13.5 - Flink CDC version: 2.2.1 - Database and version: 5.4 **To Reproduce** 

lsyldliu

DataStream api need support close incremental snapshot

3

**Is your feature request related to a problem? Please describe.** When i use Datastream Api to Collect Mysql Binlog to Kafka , I find it will error when some table...

Kyofin

Mysql DDl exception

1

I now use mysql cdc to create dataSource, after setting tableList, I can still capture ddl changes of other tables, I think this is a bug. flink version 1.13 cdc...

xuhaiL

[mysql]update primary key，Rowkind does not match the actual operation

2

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

yanghuaiGit

【oceanbase-cdc】 Could not find any factory for identifier 'oceanbase-cdc' that implements 'org.apache.flink.table.factories.DynamicTableFact ory' in the classpath.

1

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - flink-1.13.2 - Flink CDC version: 2.2.1 - Database and version: flink-sql-connector-oceanbase-cdc-2.2.1、flink-sql-connector-elasticsearch7_2.11-1.13.2 **To...

ddfeiyu

When there are spaces in the default value of the numeric type in a new table DDL under the same Mysql Host; MySQL can be executed successfully,But Flink cdc program throws some exceptions and Flink program Failed

5

**Describe the bug(Please use English)** When there are spaces in the default value of the numeric type in a new table DDL under **the same Mysql Host**; MySQL can be...

youyangkou

Error while insert data to es

2

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : flink-1.13.6 - Flink CDC version: flink-sql-connector-elasticsearch7_2.11-1.13.6.jar;flink-sql-connector-mysql-cdc-2.1.0.jar;flink-sql-connector-postgres-cdc-2.1.0.jar - Database and...

Mediterranean90

**Describe the bug** Hi Devs, I have found that in SQL mode, MySqlSourceOptions#SERVER_TIME_ZONE is set to use UTC by default, which is reasonable as this product might be used by...

kylemeow

java.lang.RuntimeException: One or more fetchers have encountered exception

10

**Describe the bug** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13.1 - Flink CDC version: 2.0.2 - Database and version: 8.0.13...

yongzhao-qcc

Compatibility problem with Flink 1.14.*

14

`java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava18/com/google/common/util/concurrent/ThreadFactoryBuilder` **Environment :** - Flink version : 1.14.3 - Flink CDC version: 2.2.0 - Database and version: MySQL 8.0.* **To Reproduce** Steps to reproduce the behavior: Class `com.ververica.cdc.debezium.DebeziumSourceFunction` in...

anavrotski