问题一:请教下 flink sql ROW_NUMBER()回退更新的机制,有相关文档介绍吗?
请教下 flink sql ROW_NUMBER()回退更新的机制,有相关文档介绍吗?
参考回答:
参考https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/sql/queries/topn/ https://zhuanlan.zhihu.com/p/658252126
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565854
问题二:Flink CDC进行数据全量同步时,一直卡在第二个节点上,可以去调整什么参数?
Flink CDC进行数据全量同步时,一直卡在第二个节点上,可以去调整什么参数?
参考回答:
找hudi连接器的配置去调试
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565529
问题三:Flink CDC你们线上一个任务,监听了多少表啊?
Flink CDC你们线上一个任务,监听了多少表啊?我发现减少表数据量就不会导致checkpoint超时了?我现在100个,之前快300吧,增量阶段checkpoint就会超时
参考回答:
你的source 和sink是分离的? 不是用flinksql处理的吧,是用datastream来处理的吗,使用Rocksdbstate,应该会好点
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565526
问题四:flink mysql cdc 同一个账号多个任务在用同一张表有影响吗?
flink mysql cdc 同一个账号多个任务在用同一张表有影响吗?
参考回答:
多任务读取同一个表不会相互影响,因为每个任务都有自己的读取路径。
但如果存在多个任务同时写入同张表,则可能导致冲突。为了解决此类冲突,建议采用锁表策略或者执行协调器来保证数据一致性。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565521