问题一:Flink CDC中SQL server CDC采集是必须要求表有primary key吗?
Flink CDC中SQL server CDC采集是必须要求表有primary key吗?
参考回答:
https://github.com/ververica/flink-cdc-connectors/issues/1152
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566150
问题二:Flink CDC中Oracle不能像Mysql这样动态加表么?
Flink CDC中Oracle不能像Mysql这样动态加表么?
参考回答:
目前不能,这个功能在做通用的, 还不支持
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566148
问题三:Flink CDC为什么UUID生产的会有问题?
Flink CDC为什么UUID生产的会有问题?
参考回答:
Flink CDC在生产UUID时出现问题,可能是因为以下几个原因:
- 数据类型不匹配:在Flink CDC中,如果你试图将UUID字段转换为其他类型,比如String,可能会出现问题。因为UUID是一种特殊的数据类型,它的存储和计算都需要特殊的处理。
- UUID生成算法问题:UUID的生成算法有很多种,不同的算法生成的UUID可能会有所不同。如果你使用的UUID生成算法存在问题,可能会导致生成的UUID不正确。
- 数据质量问题:如果你的数据来源存在问题,比如数据丢失、数据损坏等,也可能导致生成的UUID有问题。
- 系统环境问题:如果你的系统环境存在问题,比如内存不足、CPU过载等,也可能导致生成的UUID有问题。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566147
问题四:Flink CDC不需要指定 在特定位点启动模式下指定 GTID 集合 么?
"Flink CDC不需要指定 'scan.startup.specific-offset.gtid-set' = '24DA167-0C0C-11E8-8442-00059A3C7B00:1-19', -- 在特定位点启动模式下指定 GTID 集合 么?
参考回答:
只能用一种方式启动,保证从检查点启动也需要和初始的时候保持一致,你用a方式启动,保存了检查点b。你从检查点b启动还必须要用a启动方式,检查点前后的启动方式要保持一致,如果一致的情况下,你这个错误,很明显就是找不到binlog点位导致的问题
你可以找到这个009913结尾的binlog文件吗
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566146
问题五:flink stream api方式,可以在任务启动时初始化一些静态的参数放内存吗?
flink stream api方式,可以在任务启动时初始化一些静态的参数放内存吗?用于在数据流入时进行比对等操作
参考回答:
看下这个能不能作为参考
// StreamExecutionEnvironment env
// set
env.getConfig().setGlobalJobParameters(conf);
public static class T extends RichMapFunction {
@Override
public String map(String value) throws Exception {
// get
getRuntimeContext().getExecutionConfig().getGlobalJobParameters();
return null;
}
}
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566110