Fix data duplicate when restore data larger than 10*maxSegmentGroupSi…

…ze (zilliztech#121) Signed-off-by: wayblink <anyang.wang@zilliz.com>
zhuwenxing · Apr 3, 2023 · 8c05260 · 8c05260
1 parent 5c41347
commit 8c05260
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/backup_context.go b/core/backup_context.go
@@ -1477,8 +1477,8 @@ func (b BackupContext) getBackupPartitionPathsWithGroupID(ctx context.Context, b
 		zap.Int64("partitionID", partition.GetPartitionId()),
 		zap.Int64("groupId", groupId))
 
-	insertPath := fmt.Sprintf("%s/%s/%s/%v/%v/%d", backupPath, BINGLOG_DIR, INSERT_LOG_DIR, partition.GetCollectionId(), partition.GetPartitionId(), groupId)
-	deltaPath := fmt.Sprintf("%s/%s/%s/%v/%v/%d", backupPath, BINGLOG_DIR, DELTA_LOG_DIR, partition.GetCollectionId(), partition.GetPartitionId(), groupId)
+	insertPath := fmt.Sprintf("%s/%s/%s/%v/%v/%d/", backupPath, BINGLOG_DIR, INSERT_LOG_DIR, partition.GetCollectionId(), partition.GetPartitionId(), groupId)
+	deltaPath := fmt.Sprintf("%s/%s/%s/%v/%v/%d/", backupPath, BINGLOG_DIR, DELTA_LOG_DIR, partition.GetCollectionId(), partition.GetPartitionId(), groupId)
 
 	exist, err := b.storageClient.Exist(ctx, bucketName, deltaPath)
 	if err != nil {