Method for scheduling data flow task and apparatus

An apparatus for use in a distributed heterogeneous system comprising at least one working node, the apparatus comprising:

• a memory configured to store instructions;
• and
• a processor coupled to the memory and configured to execute the instructions to:
• preprocess a data flow task to obtain at least one subtask,
• classify a first subtask in the at least one subtask into a task group, wherein task groups of the distributed heterogeneous system comprise a central processing unit (CPU) task group, a graphics processing unit (GPU) task group, and a to-be-determined task group,
• allocate the first subtask to a first working node in the at least one working node according to the task group to which the first subtask belongs and a resource status of the at least one working node, and
• determine that a CPU corresponding to the first working node executes the first subtask when the first subtask belongs to the CPU task group;
• determine that a GPU corresponding to the first working node executes the first subtask when the first subtask belongs to the GPU task group;
• and determine, according to costs of executing the first subtask by a CPU and a GPU, a running platform that executes the first subtask when the first subtask belongs to the to-be-determined task group, wherein the cost comprises duration of executing the subtask.

A distributed heterogeneous system, comprising:

• at least one working node;
• and
• a scheduling apparatus configured to:
• preprocess a data flow task to obtain at least one subtask,
• classify a first subtask in the at least one subtask into a task group, wherein task groups of the distributed heterogeneous system comprise a central processing unit (CPU) task group, a graphics processing unit (GPU) task group, and a to-be-determined task group,
• allocate the first subtask to a first working node in the at least one working node according to the task group to which the first subtask belongs and a resource status of the at least one working node, and
• determine that a CPU corresponding to the first working node executes the first subtask when the first subtask belongs to the CPU task group;
• determine that a GPU corresponding to the first working node executes the first subtask when the first subtask belongs to the GPU task group;
• and determine, according to costs of executing the first subtask by a CPU and a GPU, a running platform that executes the first subtask when the first subtask belongs to the to-be-determined task group, wherein the cost comprises duration of executing the subtask.