问题一:Flink CDC中解析alter语句以生成SchemaChangeEvent 好久支持pg呢?
Flink CDC中[cdc-pipeline-connector][mysql] 解析alter语句以生成SchemaChangeEvent 好久支持pg呢?
参考答案:
你去看下3.1 plan,https://github.com/ververica/flink-cdc-connectors/issues/2861
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580728
问题二:Flink CDC目前pipeline 还是没有办法从savepoint恢复?
Flink CDC目前pipeline 还是没有办法从savepoint恢复?
参考答案:
这个flink-cdc.sh 这个脚本目前只能提交新任务,可以增强些
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580726
问题三:flinkCDC 可以取xls、log、txt、csv 这四种数据源么?
flinkCDC 可以取xls、log、txt、csv 这四种数据源么?
参考答案:
你可以用flink-sql 的batch按照一种格式来读取,这些文件也没有流的概念,用前置程序监听读取,丢到kafka再CDC
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580724
问题四:Flink CDC这个指定MYSQL binlog 位点进行同步,这个正常吗?
Flink CDC这个指定MYSQL binlog 位点进行同步,SOURCE端一直BUSY 100%,这个正常吗?
参考答案:
这种只要不挂 就让他跑跑 就是慢点,可以checkpoint加大点试下
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580720
问题五:flinkcdc pipeline 如何从savepoint恢复重启?
flinkcdc pipeline 如何从savepoint恢复重启?
参考答案:
stop的时候记录下state.savepoints.dir和execution.savepoint.path
在用命令行指定script file,自己写个脚本去管理job
关于本问题的更多回答可点击进行查看: