ddl: handle create writer error for index ingest operator (#53916) (#…

…54620) close #53791
pingcap · Jul 22, 2024 · a4cb63e · a4cb63e
1 parent 5160957
commit a4cb63e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/ddl/backfilling_operators.go b/pkg/ddl/backfilling_operators.go
@@ -575,6 +575,7 @@ func NewIndexIngestOperator(
 				writer, err := engines[i].CreateWriter(writerID)
 				if err != nil {
 					logutil.Logger(ctx).Error("create index ingest worker failed", zap.Error(err))
+					ctx.onError(err)
 					return nil
 				}
 				writers = append(writers, writer)