From 2e0f7dfe4286dca43028ca6dc84b94a1d569d3a6 Mon Sep 17 00:00:00 2001 From: godchen Date: Thu, 14 Oct 2021 17:40:42 +0800 Subject: [PATCH] Check data sync service error (#9856) Signed-off-by: godchen --- internal/datanode/data_sync_service.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/internal/datanode/data_sync_service.go b/internal/datanode/data_sync_service.go index 9fe405321f..e486a0046b 100644 --- a/internal/datanode/data_sync_service.go +++ b/internal/datanode/data_sync_service.go @@ -237,9 +237,8 @@ func (dsService *dataSyncService) initNodes(vchanInfo *datapb.VchannelInfo) erro zap.Int64("NumOfRows", us.GetNumOfRows()), ) - err = dsService.replica.addNormalSegment(us.GetID(), us.CollectionID, us.PartitionID, us.GetInsertChannel(), - us.GetNumOfRows(), &segmentCheckPoint{us.GetNumOfRows(), *us.GetDmlPosition()}) - if err != nil { + if err := dsService.replica.addNormalSegment(us.GetID(), us.CollectionID, us.PartitionID, us.GetInsertChannel(), + us.GetNumOfRows(), &segmentCheckPoint{us.GetNumOfRows(), *us.GetDmlPosition()}); err != nil { return err } } @@ -261,8 +260,10 @@ func (dsService *dataSyncService) initNodes(vchanInfo *datapb.VchannelInfo) erro zap.Int64("SegmentID", fs.GetID()), zap.Int64("NumOfRows", fs.GetNumOfRows()), ) - dsService.replica.addFlushedSegment(fs.GetID(), fs.CollectionID, fs.PartitionID, fs.GetInsertChannel(), - fs.GetNumOfRows()) + if err := dsService.replica.addFlushedSegment(fs.GetID(), fs.CollectionID, + fs.PartitionID, fs.GetInsertChannel(), fs.GetNumOfRows()); err != nil { + return err + } } dsService.fg.AddNode(dmStreamNode)