Update prefetchJob for blockio (matrixorigin#12791)

Approved by: @XuPeng-SH
ouyuanning · Nov 17, 2023 · d9fa6aa · d9fa6aa
1 parent 51d7fc1
commit d9fa6aa
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/pkg/vm/engine/tae/blockio/pipeline.go b/pkg/vm/engine/tae/blockio/pipeline.go
@@ -152,15 +152,12 @@ func prefetchJob(ctx context.Context, params PrefetchParams) *tasks.Job {
 		func(_ context.Context) (res *tasks.JobResult) {
 			// TODO
 			res = &tasks.JobResult{}
-			ioVectors, err := reader.ReadMultiBlocks(ctx,
-				params.ids, nil)
+			err := reader.GetFs().PrefetchFile(ctx, params.key.Name().String())
 			if err != nil {
 				res.Err = err
 				return
 			}
 			// no further reads
-			res.Res = nil
-			ioVectors.Release()
 			if params.reader == nil {
 				putReader(reader)
 			}