@@ -567,7 +567,7 @@ func NewTaskScheduler(ctx context.Context, idAllocator *allocator.IDAllocator, t
factorymsgstream.Factory)(*TaskScheduler,error)
```
_scheduleDdTask()_ selects tasks in a FIFO manner, thus time order is garanteed.
_scheduleDdTask()_ selects tasks in a FIFO manner, thus time order is guaranteed.
The policy of _scheduleDmTask()_ should target on throughput, not tasks' time order. Note that the time order of the tasks' execution will later be garanteed by the timestamp & time tick mechanism.