(12) 按照专利合作条约所公布的国际申请
(19) 世界知识 组织
国 际 局
(10) 国际公布号
(43) 国际公布日
2015 年 5 月 7 日 (07.05.2015)
W O 2015/061939 A 1
W P O P C T
(51)
国转 利分类号:
AGENCY);
中 国广 东 省深 圳 市 国 贸 大 厦
15
楼 西 座
G06F 9/38 (2006.01)
1521
室,
Guangdong 5 18014 (CN
) 。
(21)
国际申请号:
PCT/CN20 13/08605 5
(81)
指定国(除另 有指 明,要 求 每 一种 可 提供 的国家 保
(22)
国际申请 日:
2013
年
10
月
2 8
曰 (
28. 10.2013)
护 ):
AE, AG, AL, AM, AO, AT, AU, AZ, BA, BB, BG,
BH, BN, BR, BW, BY, BZ, CA, CH, CL, CN, CO, CR,
(25)
申飾 言:
中文
CU, CZ, DE, DK, DM, DO, DZ, EC, EE, EG, ES, FI, GB,
GD, GE, GH, GM, GT, HN, HR, HU, ID, IL, IN, IR, IS,
(26)
公布语言:
JP, KE, KG, KN, KP, KR, KZ, LA, LC, LK, LR, LS, LT,
LU, LY, MA, MD, ME, MG, MK, MN, MW, MX, MY,
(71)
申请人:华为技术有限公司 (HUAWEI
TECHNO
MZ, NA, NG, NI, NO, NZ, OM, PA, PE, PG, PH, PL, PT,
LOGIES CO., LTD.) [CN/CN];
中 国广 东 省 深 圳 市 龙
QA, RO, RS, RU, RW, SA, SC, SD, SE, SG, SK, SL, SM,
岗 区 坂 田 华 为 总 部 办 公 楼 ,
Guangdong 5 18129
ST, SV, SY, TH, TJ, TM, TN, TR, TT, TZ, UA, UG, US,
(CN)
UZ, VC, VN, ZA, ZM, Z W 。
(72)
发明人:王澜 (WANG,
Lan);
中 国广 东 省 深 圳 市 龙
(84)
指定国(除另 有指 明,要 求 每 一种 可 提供 的地 区保
岗 区 坂 田 华 为 总 部 办 公 楼 ,
Guangdong 5 18129
护 ):
ARIPO (BW, GH, GM, KE, LR, LS, MW, MZ, NA,
(CN
:) 。 智伟 (ZHI,
W ) ;
中 国广 东 省 深 圳 市龙 岗
RW, SD, SL, SZ, TZ, UG, ZM, ZW),
亚 (
AM, AZ,
区坂 田华 为 总 部 办 公 楼 ,
Guangdong 5 18129 (CN) 。
BY, KG, KZ, RU, TJ, TM),
欧 洲
(AL, AT, BE, BG, CH,
张克星 (ZHANG,
Kexing);
中 国广 东 省 深 圳 市 龙 岗
CY, CZ, DE, DK, EE, ES, FI, FR, GB, GR, HR, HU, IE,
区坂 田华 为 总 部 办 公楼 ,
Guangdong 5 18129 (CN
) 。
IS, IT, LT, LU, LV, MC, MK, MT, NL, NO, PL, PT, RO,
RS, SE, SI, SK, SM, TR), OAPI (BF, BJ, CF, CG, CI, CM,
(74)
代理人 : 深圳市深隹知识产权代理事务所 (普通
GA, GN, GQ, GW, KM, ML, MR, NE, SN, TD, TG) 。
合伙 )
(SHENPAT INTELLECTUAL PROPERTY
[见 续 页]
(54) Title: MANAGEMENT METHOD FOR STREAM PROCESSING SYSTEM, AND RELATED DEVICE AND SYSTEM
(54)
发明名称 :流 处理 系 统 的管 理 方法和 相 关 设备 及 系 统
监 测上 述N 个计 算 节点之 中的 第 一 计 算 节点 中部 署 的
第 一处理 单元 的运 行 情 况其 中 ,其 中,该运 行 情 况 包
括 资源使 用情 况和/或 处理 性 能
若监 测 到 第一 处 理单 元 的运 行 情 况 符合设 定 的处理单
元并发 实例调 整条 件 ,则调 整 第一 处理 单元 的并发 实
图
1 I Fig. 1
101 Monitoring a running condition of a first
processing unit deployed in a first calculation node c
N calculation nodes, wherein the running condition
comprises a resource usage condition and/or
processing performance
102 If it is monitored that the running condition of the
first processing unit conforms to a set concurrence
example adjustment condition of the processing unit,
adjusting a concurrence example of the first
processing unit
(57) Abstract: A management method for a stream processing system, and a related device and system. In the management method
for a stream processing system, the stream processing system comprises N calculation nodes, where N i s a positive integer. The man
agement method may comprise: monitoring a running condition of a processing unit deployed in a first calculation node o f the N cal
culation nodes; and i f it i s monitored that the running condition of the processing unit conforms to a set concurrence example adjust
ment condition of the processing unit, adjusting a concurrence example of the processing unit, the running condition comprising a
resource usage condition and/or processing performance. The solution in the embodiments of the present invention i s beneficial for
increasing the matching degree between the number o f concurrence examples o f a processing unit and the size o f data streams actu -
ally required to b e processed, thus guaranteeing the throughput o f a stream processing system and the resource utilization rate of the
stream processing system as far as possible.
(57)
摘要:
[见 续 页]
评论