From 8da1e74ddf51adaf869bb865ffc6931e4ce29676 Mon Sep 17 00:00:00 2001 From: "yonghao.fyh" Date: Wed, 3 Jun 2026 17:33:57 +0800 Subject: [PATCH 1/2] fix: fix unstable prefetch reader case --- .../common/reader/prefetch_file_batch_reader_impl_test.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp b/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp index f836bcc48..b686820d1 100644 --- a/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp +++ b/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp @@ -488,7 +488,8 @@ TEST_F(PrefetchFileBatchReaderImplTest, SetReadRangesReturnErrorWhenPushDownFail data_array, data_type_, batch_size, /*read_ranges=*/{{0, 50}, {50, 100}}, /*need_prefetch=*/true, - /*set_read_ranges_statuses=*/{Status::OK(), Status::IOError("set read ranges failed")}); + /*set_read_ranges_statuses=*/{Status::IOError("set read ranges failed"), + Status::IOError("set read ranges failed")}); ASSERT_OK_AND_ASSIGN( auto reader, From 8b17eeaa8b383506f4503067f1cb35f9533be72d Mon Sep 17 00:00:00 2001 From: "yonghao.fyh" Date: Thu, 4 Jun 2026 09:02:22 +0800 Subject: [PATCH 2/2] fix --- .../common/reader/prefetch_file_batch_reader_impl_test.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp b/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp index b686820d1..a634a5936 100644 --- a/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp +++ b/src/paimon/common/reader/prefetch_file_batch_reader_impl_test.cpp @@ -488,8 +488,8 @@ TEST_F(PrefetchFileBatchReaderImplTest, SetReadRangesReturnErrorWhenPushDownFail data_array, data_type_, batch_size, /*read_ranges=*/{{0, 50}, {50, 100}}, /*need_prefetch=*/true, - /*set_read_ranges_statuses=*/{Status::IOError("set read ranges failed"), - Status::IOError("set read ranges failed")}); + /*set_read_ranges_statuses=*/ + {Status::IOError("set read ranges failed"), Status::IOError("set read ranges failed")}); ASSERT_OK_AND_ASSIGN( auto reader,