数据处理方法、设备及存储介质
公开
摘要
本申请实施例提供一种数据处理方法、设备及存储介质。在数据处理方法中,数据源节点可将消息队列中的流式数据发送给数据转换节点进行处理;数据转换节点中的至少一个算子节点可异步地对状态进行备份,并将状态备份进度发送给数据源节点。当流式处理系统异常恢复后,数据源节点可从接收到的状态备份进度中确定用于恢复系统状态的目标备份进度,并向数据转换节点重新发送目标备份进度对应的流式数据。从而,数据转换节点中的算子节点可根据目标备份进度对应的流式数据恢复处理操作。在这种实施方式中,流式计算系统中的算子节点可异步对各自的状态进行备份,降低了对流式数据的处理过程形成的阻塞,从而提升数据的流式处理效率。
基本信息
专利标题 :
数据处理方法、设备及存储介质
专利标题(英):
暂无
公开(公告)号 :
CN114296999A
申请号 :
CN202111590388.1
公开(公告)日 :
2022-04-08
申请日 :
2021-12-23
授权号 :
暂无
授权日 :
暂无
发明人 :
袁小栋
申请人 :
阿里云计算有限公司
申请人地址 :
浙江省杭州市西湖区转塘科技经济区块12号
代理机构 :
北京太合九思知识产权代理有限公司
代理人 :
刘戈
优先权 :
CN202111590388.1
主分类号 :
G06F11/14
IPC分类号 :
G06F11/14 G06F11/20 G06F16/25
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06F
电数字数据处理
G06F11/00
错误检测;错误校正;监控
G06F11/07
响应错误的产生,例如,容错
G06F11/14
用运算中的冗余作数据的错误检测或校正,例如,通过采用导致相同结果的不同运算序列
法律状态
2022-04-08 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载