文章 2024-02-25 来自:开发者社区

Flink CPU问题之CPU利用率低如何解决

问题一:kafka-connect json格式适配问题? kafka->Flink->kafka->mysql Flink用sql处理之后数据写入kafka里面,格式为json,再用kafka-connect-jdbc将数据导出到mysql中。 使用kafka-connect是方便数据同时导出到其他存储 Flink定义输出表结构: CREATE TAB...

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

怎么提高flink cpu利用率

业务场景,flink batch ,读取大概两个亿数据的文件,然后进行flatmap处理。 flatmap处理出来的数据转换成表,并用sql 对表的数据进行 max(time),min(time),count等处理。 cpu利用率只有140%左右,机器还有很多资源,请问怎么可以提高flink cpu的利用率。*来自志愿者整理的flink邮件归档

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

Flink CPU利用率低

想问下大佬们 Flink的cpu利用率这么低吗 0.012?*来自志愿者整理的flink邮件归档

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等