1 .一种数据处理方法,其特征在于,所述方法包括:
获取查询语句的执行结果集合,其中,所述查询语句满足语句执行时间大于预设阈值,
所述执行结果集合中的每个执行结果包括查询语句、用于执行所述查询语句的分布式节点
和查询语句执行完成信息;
在确定所述执行结果集合中的查询语句执行完成信息符合预定完成类型的情况下,从
所述执行结果集合中确定与所述执行结果对应的目标分布式节点;
在所述目标分布式节点的任务执行数量大于预设目标阈值的情况下,将所述目标分布
式节点确定为出错节点,其中,所述任务执行数量表征查询语句执行完成信息符合预定完
成类型的执行结果数量;
在确定分布式集群中存在所述出错节点所包括的分片对应的备份分片的情况下,将所
述出错节点下线,其中,所述备份分片分布在所述分布式集群的除所述出错节点外的其他
节点上。
2.根据权利要求1所述的方法,其特征在于,所述方法还包括:
确定所述出错节点中至少一个分片各自的分片信息;
基于所述分片信息,从所述分布式集群的所述其他节点中查询与所述至少一个分片一
一对应的至少一个备份分片;
在确定所述分布式集群的所述其他节点上存在所述至少一个备份分片的情况下,确定
在所述分布式集群中存在所述出错节点所包括的分片对应的所述备份分片。
3.根据权利要求1所述的方法,其特征在于,在将所述出错节点下线之前,所述方法还
包括:
对所述备份分片对应其他节点进行预定任务处理,得到任务处理结果;
基于所述备份分片对应其他节点的任务处理结果,确定所述备份分片的可用状态信
息,以便在所述备份分片的可用状态信息指示所述备份分片可用的情况下,将所述出错节
点下线。
4 .根据权利要求1所述的方法,其特征在于,所述方法还包括:
从所述执行结果集合中确定所述目标分布式节点的节点标识出现数量;
根据所述节点标识出现数量,确定所述任务执行数量。
5.根据权利要求1所述的方法,其特征在于,所述方法还包括:
在确定所述分布式集群的所述其他节点上不存在所述备份分片的情况下,将所述情况
存储于日志中。
6.根据权利要求1所述的方法,其特征在于,所述从所述执行结果集合中确定与所述执
行结果对应的目标分布式节点,包括:
从所述执行结果集合中确定与所述执行结果对应的初始分布式节点;
在基于所述初始分布式节点的状态参数确定所述初始分布式节点为网络运行正常的
情况下,将所述初始分布式节点作为所述目标分布式节点。
7 .根据权利要求1所述的方法,其特征在于,所述将所述出错节点下线包括:
将所述出错节点的分片的运行标识更新为下线标识。
8.一种数据处理装置,其特征在于,所述装置包括:
获取模块,用于获取查询语句的执行结果集合,其中,所述查询语句满足语句执行时间
权 利 要 求 书
1/2 页
2
评论