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

摘要

Disclosed are a data processing method in a stream computing system, a control node and a stream computing system. The method comprises: collecting data stream information between each working node and other working nodes and processing speed information of the each working node; determining optimized concurrency of the each working node according to the collected data stream information and the processing speed information; and adjusting concurrency of the working nodes according to the optimized concurrency of the working nodes. The method and an apparatus disclosed by the present invention perform real-time adjustment on the concurrency of the working nodes according to real-time data in the stream computing system, thereby enabling a processing capability of the working nodes to meet a real-time requirement on service processing.