fix

matrixorigin · Jan 8, 2025 · 6ddf3d2 · 6ddf3d2
1 parent 97f5a11
commit 6ddf3d2
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/pkg/vm/engine/disttae/txn_table.go b/pkg/vm/engine/disttae/txn_table.go
@@ -586,7 +586,7 @@ func (tbl *txnTable) Ranges(ctx context.Context, rangesParam engine.RangesParam)
 
 func (tbl *txnTable) getObjList(ctx context.Context, rangesParam engine.RangesParam) (data engine.RelData, err error) {
 	needUncommited := rangesParam.Policy&engine.Policy_CollectUncommittedData != 0
-	objRelData := &engine_util.ObjListRelData{
+	objRelData := &readutil.ObjListRelData{
 		NeedFirstEmpty: needUncommited,
 	}
 
@@ -608,7 +608,7 @@ func (tbl *txnTable) getObjList(ctx context.Context, rangesParam engine.RangesPa
 
 	if err = ForeachSnapshotObjects(
 		tbl.db.op.SnapshotTS(),
-		func(obj logtailreplay.ObjectInfo, isCommitted bool) (err2 error) {
+		func(obj objectio.ObjectEntry, isCommitted bool) (err2 error) {
 			//if need to shuffle objects
 			if plan2.ShouldSkipObjByShuffle(rangesParam.Rsp, &obj.ObjectStats) {
 				return

diff --git a/pkg/vm/engine/readutil/relation_data.go b/pkg/vm/engine/readutil/relation_data.go
@@ -63,6 +63,10 @@ func (rd *EmptyRelationData) GetShardIDList() []uint64 {
 	panic("not supported")
 }
 
+func (rd *EmptyRelationData) Split(_ int) []engine.RelData {
+	panic("not supported")
+}
+
 func (rd *EmptyRelationData) GetShardID(i int) uint64 {
 	panic("not supported")
 }