一种提升Flink实时计算框架数据处理效率的方法
公开
摘要
本发明公开了一种提升Flink实时计算框架数据处理效率的方法，包括以下步骤：S1.检测Kafka分区个数是否大于flink申请task实例个数；S2.Flink task任务再均衡优化；通过Flink任务再均衡方法，可以显著提高实时计算的吞吐量并降低端到端的处理时延，避免flink在数据处理阶段存在较多的cpu浪费；以下将对每个步骤的实现过程做详细说明。本发明解决了现有Flink Streaming实时计算框架中在处理数据过程中遇到的部分task实例空闲，造成CPU资源浪费的问题；通过检测Kafka分区个数是否大于flink申请task实例个数，并对出现task实例空闲的情况进行任务再均衡优化，显著提高了资源利用率，进而增加了系统处理吞吐量、降低处理时延。
基本信息
专利标题 ：
一种提升Flink实时计算框架数据处理效率的方法
专利标题（英）：
暂无
公开（公告）号 ：
CN114385348A
申请号 ：
CN202111471776.8
公开（公告）日 ：
2022-04-22
申请日 ：
2021-12-06
授权号 ：
暂无
授权日 ：
暂无
发明人 ：
张璐波王全福谢巍盛
申请人 ：
天翼电子商务有限公司
申请人地址 ：
北京市昌平区未来科技城南区中国电信集团公司院内
代理机构 ：
代理人 ：
优先权 ：
CN202111471776.8
主分类号 ：
G06F9/50
IPC分类号 ：
G06F9/50
IPC结构图谱
G
G部——物理
G06
计算；推算或计数
G06F
电数字数据处理
G06F9/00
程序控制装置，例如，控制单元
G06F9/06
应用存入的程序的，即应用处理设备的内部存储来接收程序并保持程序的
G06F9/46
多道程序装置
G06F9/50
资源分配，例如，中央处理单元的
法律状态
2022-04-22 ：
公开
注：本法律状态信息仅供参考，即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载
