@@ -1435,9 +1435,11 @@ func (suite *APIsTestSuite) TestForkCollection() {
1435
1435
1436
1436
// Fork source collection
1437
1437
forkCollection := & model.ForkCollection {
1438
- SourceCollectionID : sourceCreateCollection .ID ,
1439
- TargetCollectionID : types .NewUniqueID (),
1440
- TargetCollectionName : "test_fork_collection_fork_1" ,
1438
+ SourceCollectionID : sourceCreateCollection .ID ,
1439
+ SourceCollectionLogCompactionOffset : 800 ,
1440
+ SourceCollectionLogEnumerationOffset : 1200 ,
1441
+ TargetCollectionID : types .NewUniqueID (),
1442
+ TargetCollectionName : "test_fork_collection_fork_1" ,
1441
1443
}
1442
1444
1443
1445
collection , collection_segments , err := suite .coordinator .ForkCollection (ctx , forkCollection )
@@ -1467,9 +1469,11 @@ func (suite *APIsTestSuite) TestForkCollection() {
1467
1469
1468
1470
// Attempt to fork a collcetion with same name (should fail)
1469
1471
forkCollectionWithSameName := & model.ForkCollection {
1470
- SourceCollectionID : sourceCreateCollection .ID ,
1471
- TargetCollectionID : types .NewUniqueID (),
1472
- TargetCollectionName : "test_fork_collection_source" ,
1472
+ SourceCollectionID : sourceCreateCollection .ID ,
1473
+ SourceCollectionLogCompactionOffset : 800 ,
1474
+ SourceCollectionLogEnumerationOffset : 1200 ,
1475
+ TargetCollectionID : types .NewUniqueID (),
1476
+ TargetCollectionName : "test_fork_collection_source" ,
1473
1477
}
1474
1478
_ , _ , err = suite .coordinator .ForkCollection (ctx , forkCollectionWithSameName )
1475
1479
suite .Error (err )
0 commit comments