DATA PROCESSING METHOD IN STREAM COMPUTING SYSTEM, CONTROL NODE AND STREAM COMPUTING SYSTEM

摘要

The present invention discloses a data processing method and a control node in a stream computing system, and a stream computing system, where the method includes: collecting information about data traffic between each working node and other working nodes, and processing speed information of each working node; determining an optimized parallelism degree of each working node according to the collected data traffic information and processing speed information; and adjusting a parallelism degree of the working node according to the optimized parallelism degree of the working node. According to the method and the apparatus disclosed in the present invention, a parallelism degree of a working node is adjusted in real time according to real-time data in a stream computing system, so that a processing capability of the working node can meet a real-time requirement of service processing.