@@ -726,8 +726,15 @@ func (b *BackupContext) readSegmentInfo(ctx context.Context, collecitonID int64,
726
726
NumOfRows : numOfRows ,
727
727
}
728
728
var size int64 = 0
729
+ var rootPath string
729
730
730
- insertPath := fmt .Sprintf ("%s/%s/%v/%v/%v/" , b .params .MinioCfg .RootPath , "insert_log" , collecitonID , partitionID , segmentID )
731
+ if b .params .MinioCfg .RootPath != "" {
732
+ rootPath = fmt .Sprintf ("%s/" , b .params .MinioCfg .RootPath )
733
+ } else {
734
+ rootPath = ""
735
+ }
736
+
737
+ insertPath := fmt .Sprintf ("%s%s/%v/%v/%v/" , rootPath , "insert_log" , collecitonID , partitionID , segmentID )
731
738
log .Debug ("insertPath" , zap .String ("insertPath" , insertPath ))
732
739
fieldsLogDir , _ , err := b .getStorageClient ().ListWithPrefix (ctx , b .milvusBucketName , insertPath , false )
733
740
if err != nil {
@@ -754,7 +761,7 @@ func (b *BackupContext) readSegmentInfo(ctx context.Context, collecitonID int64,
754
761
})
755
762
}
756
763
757
- deltaLogPath := fmt .Sprintf ("%s/ %s/%v/%v/%v/" , b . params . MinioCfg . RootPath , "delta_log" , collecitonID , partitionID , segmentID )
764
+ deltaLogPath := fmt .Sprintf ("%s%s/%v/%v/%v/" , rootPath , "delta_log" , collecitonID , partitionID , segmentID )
758
765
deltaFieldsLogDir , _ , _ := b .getStorageClient ().ListWithPrefix (ctx , b .milvusBucketName , deltaLogPath , false )
759
766
deltaLogs := make ([]* backuppb.FieldBinlog , 0 )
760
767
for _ , deltaFieldLogDir := range deltaFieldsLogDir {
0 commit comments