diff --git a/br/pkg/lightning/backend/local/local.go b/br/pkg/lightning/backend/local/local.go index 88819fa7d5f8a..457cc3af2e694 100644 --- a/br/pkg/lightning/backend/local/local.go +++ b/br/pkg/lightning/backend/local/local.go @@ -1693,7 +1693,10 @@ func (local *Backend) doImport(ctx context.Context, engine common.Engine, region if err != nil { firstErr.Set(err) workerCancel() - _ = workGroup.Wait() + err2 := workGroup.Wait() + if !common.IsContextCanceledError(err2) { + log.FromContext(ctx).Error("worker meets error", zap.Error(err2)) + } return firstErr.Get() }