flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
我使用 flink-cdc 同步 mysql 表到 tidb . 两个数据表的结构完全一致. 其中 mysql 表中有一个字段类型为: `STATUS` enum('1','2','3') NOT NULL DEFAULT '1' COMMENT '状态(1: 正常 2：注销 3：异常)' 我使用 flink sql 映射的类型为 `STATUS` STRING . 出现了异常:...
org.apache.flink.runtime.dispatcher.UnavailableDispatcherOperationException: Unable to get JobMasterGateway for initializing job. The requested operation is not available while the JobManager is initializing. at org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGateway(Dispatcher.java:903) ~[flink-dist_2.11-1.13.6.jar:1.13.6] at org.apache.flink.runtime.dispatcher.Dispatcher.performOperationOnJobMasterGateway(Dispatcher.java:913) ~[flink-dist_2.11-1.13.6.jar:1.13.6] at org.apache.flink.runtime.dispatcher.Dispatcher.deliverCoordinationRequestToCoordinator(Dispatcher.java:704) ~[flink-dist_2.11-1.13.6.jar:1.13.6] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native...
**Describe the bug(Please use English)** cdc connectors 2.0以上版本，debezium配置不起效 之前的版本是可以的  @leonardBang @wuchong @GOODBOY008
**Describe the bug(Please use English)** [tidb-cdc] Prompt after running for a period of time "Channel shutdown invoked" **Environment :** - Flink version : 1.13.5/1.13.6/1.14.4 - Flink CDC version: 2.2.0/2.2.1 -...
[ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: Unsupported option value 'specific-offset', the options [earliest-offset, specific-offset, timestamp] are not supported correctly, please do not use them until they're correctly supported
the class MySqlSourceConfigFactory is not support the new startupOptions
Hello! Are there any plans in the near future to support version 4.x of TiDB?
使用flink cdc提示：Caused by: java.sql.SQLSyntaxErrorException: SHOW command denied to user 'xxx'@'xxx' for table 'slave_master_info' 排查发现是用户缺少 show database 权限（参考文档），但 aliyun rds mysql 5.6 无法添加这个权限，已经和客服确认，5.7可以，请问有其他解决办法吗 
Half of the elements in `columnNames` will be null if we try to generate table schema from a `UPDATE` type log message, so we should skip these null values when...
You can implement `debeziumdeserializationschema` to support your scenario _Originally posted by @fuyun2024 in https://github.com/ververica/flink-cdc-connectors/issues/1256#issuecomment-1152504626_ same question，i wonder why update is split into create and delete？and which test case of the...
