问题一:Flink CDC用oracle-cdc?它是不是不能从ckp恢复?
Flink CDC用oracle-cdc?它是不是不能从ckp恢复。我用cdc同步oracle,中间把任务停掉,然后从ckp恢复,发现暂停期间的变更日志会漏掉,scan.mode设的:latest-offset?
参考答案:
从savepoint恢复试下
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/579980
问题二:flinkcdc读取sls日志服务sink到hologres任务老是反压怎么解决 有好的方法嘛?
flinkcdc读取sls日志服务sink到hologres任务老是反压怎么解决 有好的方法嘛?
参考答案:
holo结果表sdk模式是jdbc_copy吗,这个性能更好,再设置微批sink到holo,这样性能会更好点
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/579979
问题三:flinksqlcdc source和sink并行度可以单独设置嘛?
flinksqlcdc source和sink并行度可以单独设置嘛?我想source 和sink并行度分开设置hologres可以吗?
参考答案:
Flink SQL CDC的source并行度和sink并行度可以单独设置。你可以使用SET
语句来为source和sink分别设置并行度。
对于Hologres,假设你已经创建了一个名为hologres_sink
的Sink,你可以使用以下语句来设置source并行度和sink并行度:
SET 'execution.parallelism.default' = <source_parallelism>; -- 设置source并行度 SET 'execution.parallelism.hologres_sink' = <sink_parallelism>; -- 设置sink并行度
将<source_parallelism>
替换为你想要设置的source并行度的值,将<sink_parallelism>
替换为你想要设置的sink并行度的值。
请注意,上述语句中的hologres_sink
应该替换为你实际使用的Hologres Sink的名称。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/579978
问题四:Flink CDC发现数据库用的是EST时间,并且我没有权限去修改。能在flink中修改时间吗?
Flink CDC发现数据库用的是EST时间,并且我没有权限去修改。能在flink中修改时间吗?
参考答案:
可以,连接器的构建方法里面设置,参考下官网
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/579976
问题五:Flink CDC这两个类有什么区别么?
Flink CDC这两个类有什么区别么?
参考答案:
应该是不同版本的,
官网这里有提到。
关于本问题的更多回答可点击进行查看: