admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-02-02 01:06:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: err cannot be captured in defer in data_sync_service (#35448)

Browse Source 
https://github.com/milvus-io/milvus/issues/35447

Signed-off-by: fengjun2016 <jornfeng@gmail.com>
This commit is contained in:
CharlesFeng 2024-08-14 10:26:52 +08:00 committed by GitHub
parent c42976ee6f
commit 36d59867f3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/flushcommon/pipeline/data_sync_service.go
View File

@ -247,12 +247,15 @@ func getServiceWithChannel(initCtx context.Context, params *util.PipelineParams,
// init flowgraph
fg := flowgraph.NewTimeTickedFlowGraph(params.Ctx)
dmStreamNode, err := newDmInputNode(initCtx, params.DispClient, info.GetVchan().GetSeekPosition(), config, input)
var dmStreamNode *flowgraph.InputNode
dmStreamNode, err = newDmInputNode(initCtx, params.DispClient, info.GetVchan().GetSeekPosition(), config, input)
if err != nil {
return nil, err
}
ddNode, err := newDDNode(
var ddNode *ddNode
ddNode, err = newDDNode(
params.Ctx,
collectionID,
channelName,
@ -267,7 +270,8 @@ func getServiceWithChannel(initCtx context.Context, params *util.PipelineParams,
}
writeNode := newWriteNode(params.Ctx, params.WriteBufferManager, ds.timetickSender, config)
ttNode, err := newTTNode(config, params.WriteBufferManager, params.CheckpointUpdater)
var ttNode *ttNode
ttNode, err = newTTNode(config, params.WriteBufferManager, params.CheckpointUpdater)
if err != nil {
return nil, err
}