fix closeWriters

pingcap · Mar 3, 2023 · 394c2b7 · 394c2b7
1 parent 86b5e60
commit 394c2b7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ddl/ingest/engine.go b/ddl/ingest/engine.go
@@ -204,7 +204,7 @@ func (ei *engineInfo) newWriterContext(workerID int, unique bool) (*WriterContex
 
 func (ei *engineInfo) closeWriters() error {
 	var firstErr error
-	for wid := range ei.writerCache.Keys() {
+	for _, wid := range ei.writerCache.Keys() {
 		if w, ok := ei.writerCache.Load(wid); ok {
 			_, err := w.Close(ei.ctx)
 			if err != nil {