From 8ba57740b309fd8fc5859bdbcb7e025d7f283bd2 Mon Sep 17 00:00:00 2001 From: triump2020 Date: Mon, 9 Dec 2024 00:24:31 +0800 Subject: [PATCH] update --- pkg/vm/engine/disttae/txn_table_sharding.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/vm/engine/disttae/txn_table_sharding.go b/pkg/vm/engine/disttae/txn_table_sharding.go index 2c49f3950e6e3..ea981952743ea 100644 --- a/pkg/vm/engine/disttae/txn_table_sharding.go +++ b/pkg/vm/engine/disttae/txn_table_sharding.go @@ -280,7 +280,7 @@ func (tbl *txnTableDelegate) Ranges(ctx context.Context, rangesParam engine.Rang var blocks objectio.BlockInfoSlice var uncommitted []objectio.ObjectStats - if rangesParam.Policy != engine.Policy_CheckCommittedOnly { + if rangesParam.Policy&engine.Policy_CollectUncommittedData != 0 { uncommitted, _ = tbl.origin.collectUnCommittedDataObjs(rangesParam.TxnOffset) } err = tbl.origin.rangesOnePart(