问题一:Flink CDC有没有遇到将pg number 类型解析出来是这个值的?
Flink CDC有没有遇到将pg number 类型解析出来是这个值的?
参考答案:
这种一般是格式的问题,无法解析,
这个问题去debezium上找找,如果datastream解析mysql的的主键是无符号的bigint也是这种情况 ,
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/601351
问题二:Flink CDC怎么对oracle进行修改op对值类型呢?
Flink CDC中oracle logminer到kafka到op显示是insert ,怎么修改成 c, r, u, d可以让flink接,可以怎么对oracle进行修改op对值类型呢?
参考答案:
直接用datastream写出去,直接debezium-json格式的after里面的数据
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/601350
问题三:在Flink CDC的配置文件里面直接指定,就自动从savePoint点进行同步了?
在Flink CDC的配置文件里面直接指定,然后用flinkcdc命令启动,就自动从savePoint点进行同步了?
参考答案:
使用 Dinky 的 EXECUTE PIPELINE 语法来提交 FlinkCDC3的整库同步任务,全模式提交、作业恢复等都可以界面化使用,目前可以弥补一下这方面的短缺,后续的cdc版本会完善这些,已经在路上了
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/601337
问题四:flinkcdc3.0,使用这个命令也支持-s传递参数吗?
flinkcdc3.0,使用这个命令bash bin/flink-cdc.sh mysql-to-starrocks.yaml也支持-s传递参数吗?
参考答案:
应该只能在yaml里的Pipline那里加,比如
pipeline:
execution.savepoint.path:
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/601336
问题五:Flink CDC有没有mysql到starrockts数据库的整库同步的步骤文档?
Flink CDC有没有mysql到starrockts数据库的整库同步的步骤文档?
参考答案:
可以参考阿里云的官方文档。
——参考链接。
关于本问题的更多回答可点击进行查看: