preallocate transfer page matrixorigin#16953

Wenbin1002 · Jul 1, 2024 · 0dd20e5 · 0dd20e5
1 parent e7c6f37
commit 0dd20e5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/pkg/vm/engine/tae/db/test/db_test.go b/pkg/vm/engine/tae/db/test/db_test.go
@@ -9019,7 +9019,7 @@ func TestPersistTransferTable(t *testing.T) {
 		Pages: make(chan *model.TransferPage, 1000000),
 	}
 	go model.Cleaner.Handler()
-	page := model.NewTransferHashPage(&id1, now, false,
+	page := model.NewTransferHashPage(&id1, now, 10, false,
 		model.WithTTL(time.Second),
 	)
 	ids := make([]types.Rowid, 10)
@@ -9104,7 +9104,7 @@ func TestClearPersistTransferTable(t *testing.T) {
 	}
 	go model.Cleaner.Handler()
 
-	page := model.NewTransferHashPage(&id1, now, false,
+	page := model.NewTransferHashPage(&id1, now, 10, false,
 		model.WithTTL(time.Second),
 		model.WithDiskTTL(2*time.Second),
 	)

diff --git a/pkg/vm/engine/tae/tables/txnentries/mergeobjects.go b/pkg/vm/engine/tae/tables/txnentries/mergeobjects.go
@@ -149,7 +149,6 @@ func (entry *mergeObjectsEntry) prepareTransferPage() {
 			entry.pageIds = append(entry.pageIds, id)
 			_ = entry.rt.TransferTable.AddPage(page)
 			pages = append(pages, page)
-			k++
 		}
 		start = time.Now()
 		var blocks []objectio.BlockObject