请教一个问题,什么逻辑需要使用flinkSQL在paimon中实现,doris中有业务逻辑吗? 请教一个问题,什么逻辑需要使用flinkSQL在paimon中实现,doris中有业务逻辑吗?... 帅平大数据2025-01-22523 阅读2 评论
flink消费kafka的数据写入iceberg,数据量大导致OOM了怎么办? flink读取kafka数据,由于一些原因需要将kafka重新消费kafka的历史数据, 由于消费的数据量较大,flink会全力消费数据,这个时候回导致flink的taskmanager OOM(java.lang.... 帅平大数据2025-01-22618 阅读1 评论
flink + SR 或doris 已经实现了 实时入仓, 为啥现在技术方案上还要加一个 paimon? 请问下flink + SR 或doris 已经实现了 实时入仓, 为啥现在技术方案上还要加一个 paimon,作用和意义 好处在哪里呢?... 帅平大数据2025-01-06773 阅读1 评论
kafka 中字段为空字符串""时,导致flink sql 写 doris 字段错位如何解决? kafka 中字段为空字符串""时,导致flink sql 写 doris 字段错位如何解决?... 帅平大数据2024-12-30628 阅读1 评论
请教一下 flink 写入 doirs 的话,写入延迟和 checkpoint 间隔有关系吗? 请教一下 flink 写入 doirs 的话,写入延迟和 checkpoint 间隔有关系吗?... 帅平大数据2024-12-26638 阅读1 评论
有没有使用flink cdc把整库使用pipeline同步到starrocks的案例? 有没有使用flink cdc把整库使用pipeline同步到starrocks的案例?... 帅平大数据2024-12-26648 阅读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-26638 阅读1 评论
flink16 不能执行alter table ,能通过修改paimon的 schema-0 这个文件中的options 来实现对表的options的修改吗? flink16 不能执行alter table ,能通过修改paimon的 schema-0 这个文件中的options 来实现对表的options的修改吗?... 帅平大数据2024-12-25660 阅读1 评论