Service Scheduling Method, Apparatus, and System

A service scheduling apparatus, applied to a stream computing system, wherein the stream computing system is configured to schedule and process a service, wherein the stream computing system comprises a master control node and multiple working nodes, and wherein the master control node is configured to schedule sub-services comprised in the service to the multiple working nodes for processing;

• the apparatus comprising:
• an acquiring unit configured to acquire a stream computing application graph of the service, wherein the stream computing application graph is a logical relationship graph that is created in advance for the service and that comprises operators and moving directions of data streams between the operators, and wherein the operator in the stream computing application graph carries computational logic used for processing a sub-service that is in the service and that is corresponding to the operator;
• a dividing unit configured to divide the stream computing application graph according to operator degrees and operator potentials of the operators in the stream computing application graph acquired by the acquiring unit, and according to a division quantity for dividing the stream computing application graph, to obtain divided sub-graphs with the division quantity, wherein the operator degree is a cumulative sum of traffic weights of input-and-output traffic of the operator, and wherein the operator potential is a load degree of the operator in the stream computing application graph;
• and
• a scheduling unit configured to schedule a sub-service corresponding to an operator comprised in each divided sub-graph obtained by means of division by the dividing unit, to a working node corresponding to the divided sub-graph for processing.

A stream computing system configured to schedule and process a service, wherein the stream computing system comprises a master control node and multiple working nodes, wherein the master control node is configured to schedule sub-services comprised in the service to the multiple working nodes for processing, and wherein the master control node is configured to:

• acquire a stream computing application graph of the service, wherein the stream computing application graph is a logical relationship graph that is created in advance for the service and that comprises operators and moving directions of data streams between the operators, and the operator in the stream computing application graph carries computational logic used for processing a sub-service that is in the service and that is corresponding to the operator;
• divide the stream computing application graph according to operator degrees and operator potentials of the operators in the stream computing application graph and according to a division quantity for dividing the stream computing application graph, to obtain divided sub-graphs with the division quantity, wherein the operator degree is a cumulative sum of traffic weights of input-and-output traffic of the operator, and the operator potential is a load degree of the operator in the stream computing application graph;
• and
• schedule a sub-service corresponding to an operator comprised in each divided sub-graph to a working node corresponding to the divided sub-graph for processing.