Skip to content

Commit b50b151

Browse files
authored
executor: fix unexpected mpp grpc EOF error log (#50010)
close #50011
1 parent 596276b commit b50b151

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

pkg/executor/internal/mpp/local_mpp_coordinator.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -519,12 +519,13 @@ func (c *localMppCoordinator) receiveResults(req *kv.MPPDispatchRequest, taskMet
519519

520520
resp, err = stream.Recv()
521521
if err != nil {
522-
logutil.BgLogger().Info("mpp stream recv got error", zap.Error(err), zap.Uint64("timestamp", taskMeta.StartTs),
523-
zap.Int64("task", taskMeta.TaskId), zap.Int64("mpp-version", taskMeta.MppVersion))
524522
if errors.Cause(err) == io.EOF {
525523
return
526524
}
527525

526+
logutil.BgLogger().Info("mpp stream recv got error", zap.Error(err), zap.Uint64("timestamp", taskMeta.StartTs),
527+
zap.Int64("task", taskMeta.TaskId), zap.Int64("mpp-version", taskMeta.MppVersion))
528+
528529
// if NeedTriggerFallback is true, we return timeout to trigger tikv's fallback
529530
if c.needTriggerFallback {
530531
c.sendError(derr.ErrTiFlashServerTimeout)

0 commit comments

Comments
 (0)