问答 2023-06-18 来自:开发者社区

有没有朋友做过Flink CDC目标端为mpp 列存数据库dml入库性能的优化?

有没有朋友做过Flink CDC目标端为mpp 列存数据库dml入库性能的优化?

问答 2023-03-20 来自:开发者社区

各位大神,flinkcdc 和flink入库数据多少条,怎么计算?

各位大神,flinkcdc 和flink入库数据多少条,怎么计算?

问答 2023-03-13 来自:开发者社区

有人用flink mysql cdc + doris的吗,怎么捕获入库失败被fliter的数据?

有人用flink mysql cdc + doris的吗,怎么捕获入库失败被fliter的数据?

问答 2022-12-04 来自:开发者社区

请赐教,Flink CDC cdc反压后不再采集数据,消费端也全部入库了,数量对的上,啥原因

请赐教,Flink CDC cdc反压后不再采集数据,消费端也全部入库了,数量对的上,啥原因

问答 2022-10-01 来自:开发者社区

flink cdc sql的 ARRAY<ROW<>> 类型可以循环入库吗?

因为要把ARRAY 按 ROW 拆成多行入库。但对Kafka来说是一条JSON消息 ,只是某个Json属性映射成了ARRAY> 类型。 类似于这种格式:

文章 2022-05-13 来自:开发者社区

Flink Mysql CDC结合Doris flink connector实现数据实时入库

Flink Mysql CDC结合Doris flink connector实现数据实时入库Apache doris通过扩展支持通过 Flink 读写 doris 数仓中的数据表,目前 doris 支持 Flink 1.11.x ,1.12.x,1.13.x,Scala版本:2.12.x目前Flink doris connector目前控制入库通过两个参数:sink.batch.size :每多....

Flink Mysql CDC结合Doris flink connector实现数据实时入库
文章 2022-05-13 来自:开发者社区

Flink Mysql CDC结合Doris flink connector实现数据实时入库

Apache Doris 代码仓库地址:apache/incubator-doris 欢迎大家关注加星Apache doris通过扩展支持通过 Flink 读写 doris 数仓中的数据表,目前 doris 支持 Flink 1.11.x ,1.12.x,1.13.x,Scala版本:2.12.x目前Flink doris connector目前控制入库通过两个参数:sink.batch.siz....

文章 2022-02-17 来自:开发者社区

Iceberg 在基于 Flink 的流式数据入库场景中的应用

本文以流式数据入库的场景为基础,介绍引入 Iceberg 作为落地格式和嵌入 Flink sink 的收益,并分析了当前可实现的框架及要点。应用场景流式数据入库,是大数据和数据湖的典型应用场景。上游的流式数据,如日志,或增量修改,通过数据总线,经过必要的处理后,汇聚并存储于数据湖,供下游的应用(如报表或者商业智能分析)使用。上述的应用场景通常有如下的痛点,需要整个流程不断的优化:支持流式数据写入....

问答 2022-01-19 来自:开发者社区

Flink Doris connector 目前控制入库通过哪些参数实现?

Flink Doris connector 目前控制入库通过哪些参数实现?

问答 2021-12-07 来自:开发者社区

flink1.11查询结果每秒入库到mysql数量很少

各位大佬好,请教一个问题,在使用flink1.11消费kafka数据,查询结果写入到mysql库表时,发现读取kafka的速度很快(300条/秒),但是查询结果每秒写入mysql的条数只有6条左右,请问这是怎么回事,以及优化的点在哪里?下面是我的代码。 from pyflink.datastream import StreamExecutionEnvironment, TimeCharacte.....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注