From e7cd603e19992022534cf690e0a2ca7cd533f285 Mon Sep 17 00:00:00 2001 From: obdev Date: Wed, 28 Aug 2024 03:31:54 +0000 Subject: [PATCH] fix: int ObSharedNothingTmpFile::append_write_memory_tail_page_ --- src/storage/tmp_file/ob_shared_nothing_tmp_file.cpp | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/storage/tmp_file/ob_shared_nothing_tmp_file.cpp b/src/storage/tmp_file/ob_shared_nothing_tmp_file.cpp index 8bd564507..d91997089 100644 --- a/src/storage/tmp_file/ob_shared_nothing_tmp_file.cpp +++ b/src/storage/tmp_file/ob_shared_nothing_tmp_file.cpp @@ -1263,6 +1263,11 @@ int ObSharedNothingTmpFile::append_write_memory_tail_page_(ObTmpFileIOCtx &io_ct // for the last page, if the status of flushed_page_id_ page is not cached, // we will treat this page as a non-flushed page flushed_data_page_num_--; + if (0 == flushed_data_page_num_) { + LOG_INFO("flushed_page_id_ has been written", KPC(this)); + flushed_page_id_ = ObTmpFileGlobal::INVALID_PAGE_ID; + flushed_page_virtual_id_ = ObTmpFileGlobal::INVALID_VIRTUAL_PAGE_ID; + } } else if (is_write_back) { write_back_data_page_num_--; }