diff --git a/br/pkg/lightning/backend/local/local.go b/br/pkg/lightning/backend/local/local.go index 73de300bb1372..0f8610c3aebd5 100644 --- a/br/pkg/lightning/backend/local/local.go +++ b/br/pkg/lightning/backend/local/local.go @@ -1692,7 +1692,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() }