database/tidb
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

executor: fix unexpected mpp grpc EOF error log (#50010)

Browse Source 
close pingcap/tidb#50011
This commit is contained in:
guo-shaoge
2024-01-03 15:48:46 +08:00
committed by GitHub
parent 596276bc33
commit b50b151aed
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/executor/internal/mpp/local_mpp_coordinator.go
View File

@ -519,12 +519,13 @@ func (c *localMppCoordinator) receiveResults(req *kv.MPPDispatchRequest, taskMet
resp, err = stream.Recv()
if err != nil {
logutil.BgLogger().Info("mpp stream recv got error", zap.Error(err), zap.Uint64("timestamp", taskMeta.StartTs),
zap.Int64("task", taskMeta.TaskId), zap.Int64("mpp-version", taskMeta.MppVersion))
if errors.Cause(err) == io.EOF {
return
}
logutil.BgLogger().Info("mpp stream recv got error", zap.Error(err), zap.Uint64("timestamp", taskMeta.StartTs),
zap.Int64("task", taskMeta.TaskId), zap.Int64("mpp-version", taskMeta.MppVersion))
// if NeedTriggerFallback is true, we return timeout to trigger tikv's fallback
if c.needTriggerFallback {
c.sendError(derr.ErrTiFlashServerTimeout)