diff --git a/src/share/io/ob_io_define.cpp b/src/share/io/ob_io_define.cpp index 2a2419008..0b41b0365 100644 --- a/src/share/io/ob_io_define.cpp +++ b/src/share/io/ob_io_define.cpp @@ -121,6 +121,9 @@ const char *oceanbase::common::get_io_sys_group_name(ObIOModule module) case ObIOModule::TMP_TENANT_MEM_BLOCK_IO: ret_name = "TMP_TENANT_MEM_BLOCK_IO"; break; + case ObIOModule::SSTABLE_MACRO_BLOCK_WRITE_IO: + ret_name = "SSTABLE_MACRO_BLOCK_WRITE_IO"; + break; default: break; } diff --git a/src/share/io/ob_io_define.h b/src/share/io/ob_io_define.h index c00830d0d..2a14e6d63 100644 --- a/src/share/io/ob_io_define.h +++ b/src/share/io/ob_io_define.h @@ -66,7 +66,8 @@ enum ObIOModule { LINKED_MACRO_BLOCK_IO = 20017, HA_MACRO_BLOCK_WRITER_IO = 20018, TMP_TENANT_MEM_BLOCK_IO = 20019, - MAX_IO = 20020 + SSTABLE_MACRO_BLOCK_WRITE_IO = 20020, + MAX_IO = 20021 }; const char *get_io_sys_group_name(ObIOModule module); diff --git a/src/storage/blocksstable/ob_macro_block.cpp b/src/storage/blocksstable/ob_macro_block.cpp index fc2e1e16c..f861d4313 100644 --- a/src/storage/blocksstable/ob_macro_block.cpp +++ b/src/storage/blocksstable/ob_macro_block.cpp @@ -378,6 +378,7 @@ int ObMacroBlock::flush(ObMacroBlockHandle ¯o_handle, write_info.buffer_ = data_.data(); write_info.size_ = data_.upper_align_length(); write_info.io_desc_.set_wait_event(ObWaitEventIds::DB_FILE_COMPACT_WRITE); + write_info.io_desc_.set_group_id(ObIOModule::SSTABLE_MACRO_BLOCK_WRITE_IO); write_info.io_timeout_ms_ = std::max(GCONF._data_storage_io_timeout / 1000, DEFAULT_IO_WAIT_TIME_MS); if (OB_FAIL(macro_handle.async_write(write_info))) { STORAGE_LOG(WARN, "Fail to async write block", K(ret), K(macro_handle), K(write_info));