diff --git a/pkg/disttask/framework/taskexecutor/manager.go b/pkg/disttask/framework/taskexecutor/manager.go
index 13bfa6b14a561..30042ea1ec772 100644
--- a/pkg/disttask/framework/taskexecutor/manager.go
+++ b/pkg/disttask/framework/taskexecutor/manager.go
@@ -232,6 +232,7 @@ func (m *Manager) onRunnableTasks(tasks []*proto.Task) {
 		})
 		// pool closed.
 		if err != nil {
+			m.slotManager.free(t.ID)
 			m.removeHandlingTask(task.ID)
 			m.logErr(err)
 			return