From 91906ee32ae93fb1272ace98ff4d6be4ce1a8fc9 Mon Sep 17 00:00:00 2001 From: jinhelin Date: Mon, 25 Jul 2022 12:08:20 +0800 Subject: [PATCH] fix sched_setaffinity failed. --- .../src/Storages/DeltaMerge/ReadThread/SegmentReader.cpp | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/dbms/src/Storages/DeltaMerge/ReadThread/SegmentReader.cpp b/dbms/src/Storages/DeltaMerge/ReadThread/SegmentReader.cpp index 77806fdef72..e702cfe3689 100644 --- a/dbms/src/Storages/DeltaMerge/ReadThread/SegmentReader.cpp +++ b/dbms/src/Storages/DeltaMerge/ReadThread/SegmentReader.cpp @@ -69,10 +69,13 @@ class SegmentReader int ret = sched_setaffinity(0, sizeof(cpu_set), &cpu_set); if (ret != 0) { - LOG_FMT_ERROR(log, "sched_setaffinity fail: {}", std::strerror(errno)); - throw Exception(fmt::format("sched_setaffinity fail: {}", std::strerror(errno))); + // It can be failed due to some CPU core cannot access, such as CPU offline. + LOG_FMT_ERROR(log, "sched_setaffinity cpus {} fail: {}", cpus, std::strerror(errno)); + } + else + { + LOG_FMT_DEBUG(log, "sched_setaffinity cpus {} succ", cpus); } - LOG_FMT_DEBUG(log, "sched_setaffinity cpus {} succ", cpus); #endif }