From 79ab9377d40adc400abd095ffa96d55d2c18496c Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 3 Sep 2024 13:32:15 +0000 Subject: [PATCH] fix delete group failed --- src/share/io/ob_io_manager.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/share/io/ob_io_manager.cpp b/src/share/io/ob_io_manager.cpp index 7a4677cea..b9409505f 100644 --- a/src/share/io/ob_io_manager.cpp +++ b/src/share/io/ob_io_manager.cpp @@ -1864,7 +1864,7 @@ int ObTenantIOManager::delete_consumer_group_config(const int64_t group_id) // 4.clock设置为stop,但是不会析构 // 5.io_usage暂不处理 for (uint8_t i = (uint8_t)ObIOMode::READ; i <= (uint8_t)ObIOMode::MAX_MODE; ++i) { - uint64_t index = INT_MAX64; + uint64_t index = INT64_MAX; DRWLock::WRLockGuard guard(io_config_lock_); ObIOMode mode = (ObIOMode)i; ObIOGroupKey key(group_id, mode); @@ -1892,7 +1892,7 @@ int ObTenantIOManager::delete_consumer_group_config(const int64_t group_id) LOG_WARN("modify group io config failed", K(ret), K(tenant_id_), K(index)); } } - if (OB_SUCC(ret) && index != 0) { + if (OB_SUCC(ret) && index != 0 && index != INT64_MAX) { if (OB_FAIL(io_scheduler_->stop_phy_queues(tenant_id_, index))) { LOG_WARN("stop phy queues failed", K(ret), K(tenant_id_), K(index)); } else {