问题一:Flink mysql cdc全量阶段现在支持select *字段自定义吗?
Flink mysql cdc全量阶段现在支持select 字段自定义吗?每次select ,有的字段数据量特别大,其实作业根本用不到这个字段
参考答案:
还不支持,后边Flink CDC 3.0 会支持,在630左右。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/605982
问题二:Flink这个参数是针对这个作业的所有流的状态保留时间吗?
Flink这个参数是针对这个作业的所有流的状态保留时间吗?我的SQL中关联的一张表,有些数据一开始是正确的,后面会被更新成0,猜测是这张表的状态过期了,数据没关联上,是修改这个参数吗?
参考答案:
这个参数的意思是:如果时间超过了State数据过期时间,则State数据就过期了,系统就会自动清理掉过期的State数据,即可释放一定的磁盘空间。文档链接:https://help.aliyun.com/zh/flink/user-guide/configure-a-deployment?spm=a2c4g.11186623.0.0.52264201X6vsvh
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/605981
问题三:flink的jar包任务,如果要配置日志级别修改为debug,这个是在哪里改呢?
flink的jar包任务,如果要配置日志级别修改为debug,这个是在哪里改呢?
参考答案:
日志配置右边有个编辑,可以修改
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/605980
问题四:Flink中selectDB 可以做为 源数据 吗?是不是selectDB没有binlog?
Flink中selectDB 可以做为 源数据 吗?是不是selectDB没有binlog?
参考答案:
是的,他自己没有。可以考虑Hologres。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/605979
问题五:如何在 Flink 中配置目标表的并行度或解决TEMPORARY TABLE更新慢的问题?
如何在 Flink 中配置目标表的并行度或解决TEMPORARY TABLE更新慢的问题?具体场景如下:
使用元数据 select-db.center_risk_service.data_model_user 作为目标表时,应如何设置 'sink.parallelism' = '3'?
如果使用 TEMPORARY TABLE 作为目标表,如何解决更新慢的问题?(如果问题1无法解决,可能只能选用 TEMPORARY TABLE)
参考答案:
您好,若使用元数据 select-db
.center_risk_service.data_model_user 做为目标表,那么您可以在sink表后面加上
/+ OPTIONS('sink.parallelism' = '3') / 来设置参数 。至于使用 TEMPORARY TABLE 做为目标表出现的同步慢问题,一般是从源端读取数据慢,下游busy繁忙导致的上游反压有延迟等。
关于本问题的更多回答可点击进行查看: