热文Dinky上使用flinksql导入数据到starrocks报错,提示:call frontend service failed怎么办? Dinky上使用flinksql导入数据到starrocks报错,提示: java.lang.RuntimeException: com.starrocks.data.load.stream.exception.St... 帅平数据库2024-12-251065 阅读1 评论
热文Doris实战系列(四)Doris+paimon+minio+flink实战案例 本文再介绍一个案例,结合目前比较流行的组合:doris+paimon+flink+minio的组合,实现使用flink把数据写入paimon中,数据真实存储在minio中,再使用doris进行读取。下面直接演示。具体... 帅平doris系列2024-12-242587 阅读0 评论
Flink sql中如何在streaming模式和batch模式下切换? Flink sql中如何在streaming模式和batch模式下切换?... 帅平大数据2024-12-24678 阅读2 评论
在dinky中使用flink和paimon报错,提示:NoSuchMethodError: 'org.apache.htrace.core.Tracer怎么办? 在dinky中使用flink和paimon报错,结果提示报错了: Caused by: java.lang.NoSuchMethodError: 'org.apache.htrace.core.Tracer org.... 帅平大数据2024-12-19846 阅读1 评论
flink-doris-connector目前支持的schema change有哪些? flink-doris-connector目前支持的schema change有哪些?... 帅平数据库2024-12-19664 阅读1 评论
doris的flink-doris-connector如何忽略源端的delete操作? doris的flink-doris-connector如何忽略源端的delete操作?... 帅平数据库2024-12-18639 阅读1 评论
热文Doris实战系列(二)Flink-cdc-mysql整库同步到doris(实现表schema动态变更) 在日常的大数据场景里面,我们经常会涉及到使用flink-cdc把源数据同步到数据仓库或者数据湖中,所以这里我们演示一下使用flink-cdc把mysql的数据同步到doris中。下面直接开始:一、前置条件这里我们演示... 帅平doris系列2024-12-181574 阅读1 评论
热文Flink1.20 cdc中同步任务的时候出现ClassNotFoundException: org.apache.flink.cdc.debezium.DebeziumDeserialization Flink1.20 cdc中同步任务的时候报错了,提示: Caused by: java.lang.ClassNotFoundException: org.apache.flink.cdc.debezium.Debe... 帅平大数据2024-12-181115 阅读3 评论
使用flink sink doris的时候label查看不到为什么? flink sink doris的时候,使用show load看不到label,请问是怎么回事?... 帅平数据库2024-11-05556 阅读2 评论
flink-sql映射iotdb的序列有特殊字符,你们是怎么转换的? flink-sql映射iotdb的序列有特殊字符,你们是怎么转换的?这种形式的,有-解析不出来,会报错 org.apache.flink.sql.parser.impl.ParseException: Encount... Rae大数据2024-10-12672 阅读1 评论
请教一下 使用flinkcdc整库同步mysql到doris,报错: Caused by: java.lang.NoSuchMethodError 请教一下 使用flinkcdc整库同步mysql到doris,报错: Caused by: java.lang.NoSuchMethodError: io.debezium.connector.mysql.MySql... 帅平大数据2024-07-27883 阅读3 评论