问题一:Flink CDC里dlink 整库同步 支持字段变更吗 ?
Flink CDC里dlink 整库同步 支持字段变更吗 ?flink 任务 运行过程中,source 表 添加了一个字段,能获取到,然后同步到sink表中是吧?
参考答案:
支持,但是支持的sink数据库不多,详细看官网。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590799
问题二:Flink CDC版本2.2.1,并行度设为2,指定了serverId之后只能读到全量、增量怎么办?
Flink CDC里cdc版本2.2.1,并行度设为2,指定了serverId之后只能读到全量、读不到增量,怎么解决?
参考答案:
检查是否开启checkpoint。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590798
问题三:Flink CDC里请问我已经都把包放到flink/lib下面了,为什么还是不行?
Flink CDC里请问我已经都把包放到flink/lib下面了,为什么还是不行?在linux上面flink这样可以,到docker里面的flink就不行了是为什么?
参考答案:
可能的原因有以下几点:
- Docker容器中的Flink和Linux上的Flink版本不同,导致依赖包不兼容。请确保在Docker容器中使用的Flink版本与Linux上的Flink版本一致。
- 在Docker容器中,Flink的lib目录可能没有正确挂载到宿主机。请检查Dockerfile中的VOLUME设置,确保将Flink的lib目录挂载到宿主机的相应位置。
- 在Docker容器中,可能存在类路径(Classpath)问题。请检查Flink的配置文件(flink-conf.yaml),确保所有需要的依赖包都已经被添加到类路径中。
- 如果以上都没有问题,可以尝试在Docker容器中手动添加缺失的依赖包,然后重新启动Flink。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590797
问题四:Flink CDC里怎么看消费当前binlog的位置?
Flink CDC里怎么看flink cdc消费当前binlog的位置?比如canal消费binlog会有个专门的日志文件记录当前的消费位置。
参考答案:
看日志。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590796
问题五:Flink CDC里applcation model模式和sql client可以一起用吗?
Flink CDC里flink的applcation model模式和sql client可以一起用吗?
参考答案:
找个开发平台。比如dinky 的
http://www.dlink.top/docs/next/user_guide/studio/all_task_devlop
关于本问题的更多回答可点击进行查看: