如果我的cdc所有库表的数据都在kafka,采用一种什么方式进行doris持久化落ods表比较合适呢? 如果我的cdc所有库表的数据都在kafka,采用一种什么方式进行doris持久化落ods表比较合适呢?... 帅平大数据2025-07-31431 阅读1 评论
想要做数仓ods层数据同步,使用FlickCDC好还是SeaTunnel好? 想要做数仓ods层数据同步,使用FlickCDC好还是SeaTunnel好?... Rae大数据2025-05-07528 阅读1 评论
请问您下Doris operator 启动BE 报错 lastStreamLoadTime":-1,"isQueryDisabled":false 请问您下Doris operator 启动BE 报错: lastStreamLoadTime":-1,"isQueryDisabled":false,"isLoadDisabled":false} 9 . [Tue ... Rae运维2025-04-08495 阅读1 评论
flinkcdc 如果把参数 sink.parallelism 值设成大于1,这不会导致sink 出来的消息是乱序的吗? flinkcdc 如果把参数 sink.parallelism 值设成大于1,这不会导致sink 出来的消息是乱序的吗?意思是和binlog 里SQL实际执行顺序不一致... Rae大数据2025-02-28549 阅读1 评论
请问从pgsql实时同步到自建doris目前最成熟的方案是用flinkcdc吗,还有其他可行方案没? 请问从pgsql实时同步到自建doris目前最成熟的方案是用flinkcdc吗,还有其他可行方案没?... 帅平大数据2025-02-19550 阅读1 评论
咨询一下seatunnel 2.3.8,mysqlcdc 到doris 多表同步,需要加什么参数才会自动同步表结构变更呀? 咨询一下seatunnel 2.3.8,mysqlcdc 到doris 多表同步,需要加什么参数才会自动同步表结构变更呀?... 帅平大数据2024-12-27573 阅读1 评论
有没有使用flink cdc把整库使用pipeline同步到starrocks的案例? 有没有使用flink cdc把整库使用pipeline同步到starrocks的案例?... 帅平大数据2024-12-26635 阅读2 评论
Flink cdc把数据同步到doris中报错,提示:org.dinky.cdc.doris.DorisSinkBuilder Unable to get public no-arg construc Flink cdc把数据同步到doris中报错,提示:: Caused by: java.util.ServiceConfigurationError: org.dinky.cdc.SinkBuilder: org.... 帅平大数据2024-12-26625 阅读1 评论
热文Doris实战系列(二)Flink-cdc-mysql整库同步到doris(实现表schema动态变更) 在日常的大数据场景里面,我们经常会涉及到使用flink-cdc把源数据同步到数据仓库或者数据湖中,所以这里我们演示一下使用flink-cdc把mysql的数据同步到doris中。下面直接开始:一、前置条件这里我们演示... 帅平doris系列2024-12-181554 阅读1 评论
flinkcdc实时同步mysql维度表到doris,mysql的删除会在doris当中删除吗? 大佬们请问下,flinkcdc实时同步mysql维度表到doris,mysql的删除会在doris当中删除吗?删除这个要怎么实现... 帅平数据库2023-09-21681 阅读1 评论
热文Dinky 实时计算平台系列(二十二)FlinkSql作业开发之FlinkSql-cdc + doris 在日常的业务场景中,我们使用flink做cdc的工作的时候,大多数都有这样的需求,把mysql的数据近视的导入到doris中做分析。为了方便简写代码,这里我们使用Dinky来演示下把mysql的数据使用cdc同步到d... Raeflink系列2023-09-052720 阅读0 评论