diff --git a/scheduler/queue/dispatcher.go b/scheduler/queue/dispatcher.go
index 3ec363f8ca..617157da4a 100644
--- a/scheduler/queue/dispatcher.go
+++ b/scheduler/queue/dispatcher.go
@@ -288,6 +288,7 @@ func (d *Dispatcher) Dispatch(ctx context.Context, tableClients []TableClientPai
 			jobs <- item
 		}
 		close(jobs)
+		close(newJobs)
 	}()
 
 	go func() {