From b9feeab15f0185fc9e8aa403dcaa2c21143e4068 Mon Sep 17 00:00:00 2001 From: Ten Thousand Leaves <69466447+soothing-rain@users.noreply.github.com> Date: Mon, 10 Oct 2022 09:45:21 +0800 Subject: [PATCH] Do not try to report task state when DataNode itself is down (#19647) /kind bug issue: #19502 Signed-off-by: Yuchen Gao Signed-off-by: Yuchen Gao --- internal/datanode/data_node.go | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/internal/datanode/data_node.go b/internal/datanode/data_node.go index cf1d257b67..0db741aafa 100644 --- a/internal/datanode/data_node.go +++ b/internal/datanode/data_node.go @@ -982,16 +982,9 @@ func (node *DataNode) Import(ctx context.Context, req *datapb.ImportTaskRequest) zap.Int64("taskID", req.GetImportTask().GetTaskId()), zap.Error(errDataNodeIsUnhealthy(Params.DataNodeCfg.GetNodeID()))) - msg := msgDataNodeIsUnhealthy(Params.DataNodeCfg.GetNodeID()) - importResult.State = commonpb.ImportState_ImportFailed - importResult.Infos = append(importResult.Infos, &commonpb.KeyValuePair{Key: "failed_reason", Value: msg}) - reportErr := reportFunc(importResult) - if reportErr != nil { - log.Warn("fail to report import state to root coord", zap.Error(reportErr)) - } return &commonpb.Status{ ErrorCode: commonpb.ErrorCode_UnexpectedError, - Reason: msg, + Reason: msgDataNodeIsUnhealthy(Params.DataNodeCfg.GetNodeID()), }, nil }