问题一:Flink CDC中 doris字段怎么做到和原表统一啊,能做到自动化吗?
Flink CDC中 doris字段怎么做到和原表统一啊,能做到自动化吗?
参考答案:
自动化能做到也是在代码里做
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580665
问题二:flinkcdc写doris,mysql字段变更,重新提交才能同步新字段数据嘛?
flinkcdc写doris,mysql字段变更,doris字段不会自动添加,想生效必须 手动添加doris字段,然后修改flinksql代码 重新提交才能同步新字段数据嘛?
参考答案:
除非你写代码。自己识别他序列化过来的数据。然后自动生成插入语句。这样的话任务提交后,你源表结构发生改变有问题了,你将doris字段与源表统一,可以不修改代码。代码写的好可以不重新提交,写的不好有可能还得提交
https://github.com/ververica/flink-cdc-connectors/issues/2600
https://docs.google.com/document/d/1tJ0JSnpe_a4BgLmTGQyG-hs4O7Ui8aUtdT4PVIkBWPY/edit
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580663
问题三:flinkcdc需要重新添加字段在提交才能同步新字段吗?
flinkcdc实时读mysqlbinlog 写doris,mysql字段添加, doris字段不会自动添加,但是如果手动添加doris字段,flinksql source和sink需要重新添加字段在提交才能同步新字段吗?不会自动同步新字段数据吗?
参考答案:
如果你用flinksql的肯定要重新运行的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580661
问题四:mysql 添加字段FlinkCDC监听不到吗?
mysql 添加字段FlinkCDC监听不到吗?请问官方文档哪里有提到https://ververica.github.io/flink-cdc-connectors/master/content/connectors/mysql-cdc%28ZH%29.html#id1mysql cdc我没有找到相关介绍 求教
参考答案:
添加字段可以监听到,你试一下就知道了,你表结构发生改变,你后面的binlog和以前的结构就不一样了,而且cdc是捕捉变化的数据
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/580658
问题五:Flink CDC这个checkpoint是指每次读取binlog日志的间隔时间吗?
Flink CDC这个checkpoint是指每次读取binlog日志的间隔时间吗?
参考答案:
不是,是发生故障自己断点重启用的,那个是定时刷check point
关于本问题的更多回答可点击进行查看: