Skip to content

Commit 06422f4

Browse files
committed
fix comment
1 parent a34651f commit 06422f4

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

pkg/disttask/framework/taskexecutor/manager.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -232,6 +232,7 @@ func (m *Manager) onRunnableTasks(tasks []*proto.Task) {
232232
})
233233
// pool closed.
234234
if err != nil {
235+
m.slotManager.free(t.ID)
235236
m.removeHandlingTask(task.ID)
236237
m.logErr(err)
237238
return

0 commit comments

Comments
 (0)