开源数据集成工具
创新数据集成,驱动业务发展
知识百科 • 数栈君 发表了文章 • 0 个评论 • 147 次浏览 • 2024-07-05 11:49
flink的checkpoint机制,在chunjun中是否有意义?
回复ChunJun • 匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 681 次浏览 • 2023-02-02 10:30
请问一下,flink有办法让上游数据均匀分配到下游的map算子么,试了下shuffle和rebalance都会有比较严重的数据倾斜
回复ChunJun • 匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 354 次浏览 • 2023-07-11 14:40
有没有flinkx 1.12.7版本的mysql的cdc写入doris的案例,感谢
回复ChunJun • 匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 383 次浏览 • 2023-07-11 14:40
你好,目前我遇到一个问题,就是我用mysqlcdc进行实时采集时,如果任务停止后,在原表手动插入一条数据再启动原任务,以后就再也不会有数据采进来,也不会报错,有什么办法可以解决吗?
回复ChunJun • 匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 368 次浏览 • 2023-07-11 14:40
这个是不是只能在 standalone的模式能用?Per-job 模式能增量同步么
回复ChunJun • 匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 358 次浏览 • 2023-07-11 14:36
请问一下,chunjun kafkasource中的group-offsets模式,是否是在指定新group时从offset1开始消费,指定旧group时从上次消费过的offset开始消费
回复ChunJun • 匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 552 次浏览 • 2023-03-24 11:20
创新数据集成,驱动业务发展
知识百科 • 数栈君 发表了文章 • 0 个评论 • 147 次浏览 • 2024-07-05 11:49