flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
when scan newly added tables if i set startupOptions=StartupOptions.latest() throw Error ERROR io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Encountered change event 'Event{header=EventHeaderV4{timestamp=1653474984000, eventType=TABLE_MAP, serverId=1, headerLength=19, dataLength=33, nextPosition=999048757, flags=0}, data=TableMapEventData{tableId=302, database='test', table='src', columnTypes=15, 15,...
linked #1558 1 make sure mac with apple silicon chip can run the test case. 2 define the expose port 8081:8081 in JobManager's container.So when container is running, Flink web...
I want to debug the code with module flink-cdc-e2e-tests in IDE. While,although I have run the docker desktop in my mac.An exception still been throwed like this The current code...
**Describe the bug(Please use English)** We have found that during the MySQL snapshot phase, a transaction is initiated but never committed, resulting in the transaction being left there for a...
使用flinkcdc Oracle 会在Oracle库中生成LOG_MINING_FLUSH表，里面只有一个字段一个值LAST_SCN并且在一直变化中，这个表有什么作用呢。能不能解释一下。
草率了. 使用了postgres14+ 想用CDC做数据同步 发现没有这个版本 请问有没有计划支持 postgres14 什么时候能支持.
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....
**Describe the bug(Please use English)** #### KeyRange in TableKeyRangeUtils distribution is unreasonable. Scan tidb table is not divided between different subtasks **Environment :** - Flink version : flink 1.14 -...
**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.14.3 - Flink CDC version: 2.2.1 - Database and...
