From 7632681a665aca5e10b049ecd28e31be45f48f49 Mon Sep 17 00:00:00 2001 From: guo-shaoge Date: Wed, 3 Jan 2024 14:06:58 +0800 Subject: [PATCH] executor: fix unexpected mpp grpc EOF error log Signed-off-by: guo-shaoge --- pkg/executor/internal/mpp/local_mpp_coordinator.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/executor/internal/mpp/local_mpp_coordinator.go b/pkg/executor/internal/mpp/local_mpp_coordinator.go index 3388ee2d89121..bb91bba1474e3 100644 --- a/pkg/executor/internal/mpp/local_mpp_coordinator.go +++ b/pkg/executor/internal/mpp/local_mpp_coordinator.go @@ -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)