flink-cdc issues

请问一下大佬们，flink cdc 连接TiDB，支持获取 TiDB 的 DDL 吗？

2

请问一下大佬们，flink cdc 连接TiDB，支持获取 TiDB 的 DDL 吗？

MengXiangDing

enhancement

oracle-es的demo报错ORA-00955: 名称已由现有对象使用

1

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

zhuxt2015

bug

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

6

**Describe the bug(Please use English)** ERROR MESSAGE: `java.lang.RuntimeException: One or more fetchers have encountered exception at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:223) at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:154) at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:116) at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:305) at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:69) at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:66) at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:423) at...

wpx1997-stack

bug

[mysql]binlog file validation error when switch mysql cluster

1

**Describe the bug(Please use English)** During binlogReader phase, it will checks whether the binlog file exists first.In master/slave mode,If I switch from cluster A to cluster B and restore from...

xiaoyu19950911

bug

oracle cdc TIMESTAMP WITH TIME ZONE

1

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

bluewaterstar

bug

[postgres] Add changelog mode configuration with upsert/retract modes

2

This PR implements #1241 proposal with generic code but exposing support in configuration just for postgres module. I am opening the PR to share one possible implementation of my proposal...

fbad

flink cdc Oracle 在监听oracle日志期间,监听表添加了字段,导致丢数据

1

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

XiaoXin101

bug

mysql cdc add new table restore from sp but lost data.数据丢失从sp恢复.

2

**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.1 - Database and...

MyLanPangzi