问题一:flinkcdc 3.0 如何配置savepoint?
flinkcdc 3.0 如何配置savepoint , 我在 3.0的文档里没看到, 现在任务失败之后,还需要手动设置 同步时间吗?
参考答案:
在flink-conf里面配置检查点路径,再重新启动。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602807
问题二:Flink CDC 里这样合理吗?
Flink CDC中,这出现这个合理吗?
参考答案:
可以写范围的,比如'5800-5804'。增量阶段只有1了;而且并行度不需要在代码写死,server-id可以写死,写最大就行了。另外server-id设置范围,但是你的并行度是1,他也只会从你的sever-id选1个。server-id范围>=并行度。然后你并行度是5,他也只会从你的范围里面选5个server-id,而不是全部用。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602803
问题三:如果我没有给FlinkCDC单独指定并行度,它的并行度是1,还是跟整个Flink任务的并行度一致?
如果我没有给FlinkCDC单独指定并行度,它的并行度是1,还是跟整个Flink任务的并行度一致?
参考答案:
和flink默认并行度一致。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602802
问题四:做flink cdc2doris的操作时,新建一个任务,设置从最早的 binlog 开始同步正常吗?
做flink cdc2doris的操作时,新建一个任务,设置从最早的 binlog 开始同步(scan.startup.mode=earliest-offset)没有问题,然后新加一张表,从savepoint启动后发现新加的表是从最新的binlog开始同步数据的。是正常现象么?
参考答案:
动态加表推荐使用默认的启动
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602801
问题五:FlinkCDC监听oracle 19C的,读取出来的Timestamp类型,增加了8小时,咋解决?
FlinkCDC监听oracle 19C的,读取出来的Timestamp类型,增加了8小时,可以设置哪个参数解决这个问题呢?
参考答案:
目前应该没有。或者这个可能需要自己转下, timestamp和date类型。
关于本问题的更多回答可点击进行查看: