基于Flink的任务执行方法、装置、计算机设备及存储介质
授权
摘要
本申请实施例属于计算机技术领域,应用于智慧社区领域中,涉及一种基于Flink的任务执行方法、装置、计算机设备及存储介质包括基于版本号将接收到的Flink数据包存储至预先建立的子目录文件夹中;基于接收到的用户任务数据确定目标Flink版本号;基于目标Flink版本号,基于目标Flink版本号确定出目标子目录文件夹,将目标子目录文件夹中的Flink数据包作为目标Flink数据包并加载至内存;获取用户任务数据中的任务分配方式和待处理数据,在向各服务器分配的待处理数据的数据量不均匀时,调用预设的数据分配方式重新向各服务器分配所述待处理数据;运行内存中的目标Flink数据包。Flink数据包可存储于区块链中。本申请能够支持不同版本Flink任务的调用,同时避免Flink版本调用混乱的情况。
基本信息
专利标题 :
基于Flink的任务执行方法、装置、计算机设备及存储介质
专利标题(英):
暂无
公开(公告)号 :
CN113254106A
申请号 :
CN202110698927.7
公开(公告)日 :
2021-08-13
申请日 :
2021-06-23
授权号 :
CN113254106B
授权日 :
2022-04-19
发明人 :
李金阳
申请人 :
中国平安人寿保险股份有限公司
申请人地址 :
广东省深圳市福田区益田路5033号平安金融中心14、15、16、37、41、44、45、46层
代理机构 :
深圳市世联合知识产权代理有限公司
代理人 :
汪琳琳
优先权 :
CN202110698927.7
主分类号 :
G06F9/445
IPC分类号 :
G06F9/445
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06F
电数字数据处理
G06F9/00
程序控制装置,例如,控制单元
G06F9/06
应用存入的程序的,即应用处理设备的内部存储来接收程序并保持程序的
G06F9/44
用于执行专门程序的装置
G06F9/445
程序的加载或启动
法律状态
2022-04-19 :
授权
2021-10-12 :
实质审查的生效
IPC(主分类) : G06F 9/445
申请日 : 20210623
申请日 : 20210623
2021-08-13 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载