@@ -867,16 +867,18 @@ func (tc *Catalog) ForkCollection(ctx context.Context, forkCollection *model.For
867867 }
868868
869869 createCollection := & model.CreateCollection {
870- ID : forkCollection .TargetCollectionID ,
871- Name : forkCollection .TargetCollectionName ,
872- ConfigurationJsonStr : sourceCollection .ConfigurationJsonStr ,
873- Dimension : sourceCollection .Dimension ,
874- Metadata : sourceCollection .Metadata ,
875- GetOrCreate : false ,
876- TenantID : sourceCollection .TenantID ,
877- DatabaseName : sourceCollection .DatabaseName ,
878- Ts : ts .Unix (),
879- LogPosition : sourceCollection .LogPosition ,
870+ ID : forkCollection .TargetCollectionID ,
871+ Name : forkCollection .TargetCollectionName ,
872+ ConfigurationJsonStr : sourceCollection .ConfigurationJsonStr ,
873+ Dimension : sourceCollection .Dimension ,
874+ Metadata : sourceCollection .Metadata ,
875+ GetOrCreate : false ,
876+ TenantID : sourceCollection .TenantID ,
877+ DatabaseName : sourceCollection .DatabaseName ,
878+ Ts : ts .Unix (),
879+ // TODO: Inherit log position after log fork is implemented
880+ // LogPosition: sourceCollection.LogPosition,
881+ LogPosition : 0 ,
880882 TotalRecordsPostCompaction : sourceCollection .TotalRecordsPostCompaction ,
881883 SizeBytesPostCompaction : sourceCollection .SizeBytesPostCompaction ,
882884 LastCompactionTimeSecs : sourceCollection .LastCompactionTimeSecs ,
0 commit comments