From ed81a44f4f88f3fbdc866e59c3886bacaf9d1dfb Mon Sep 17 00:00:00 2001 From: Kseniia Sumarokova <54203879+kssenii@users.noreply.github.com> Date: Fri, 13 Dec 2024 12:14:56 +0100 Subject: [PATCH] Update getThreadPoolReader.cpp --- src/Disks/IO/getThreadPoolReader.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/Disks/IO/getThreadPoolReader.cpp b/src/Disks/IO/getThreadPoolReader.cpp index 7dbff9ffe76..811579d6dff 100644 --- a/src/Disks/IO/getThreadPoolReader.cpp +++ b/src/Disks/IO/getThreadPoolReader.cpp @@ -32,14 +32,14 @@ std::unique_ptr createThreadPoolReader( { case FilesystemReaderType::ASYNCHRONOUS_REMOTE_FS_READER: { - auto pool_size = config.getUInt(".threadpool_remote_fs_reader_pool_size", 250); - auto queue_size = config.getUInt(".threadpool_remote_fs_reader_queue_size", 1000000); + auto pool_size = config.getUInt("threadpool_remote_fs_reader_pool_size", 250); + auto queue_size = config.getUInt("threadpool_remote_fs_reader_queue_size", 1000000); return std::make_unique(pool_size, queue_size); } case FilesystemReaderType::ASYNCHRONOUS_LOCAL_FS_READER: { - auto pool_size = config.getUInt(".threadpool_local_fs_reader_pool_size", 100); - auto queue_size = config.getUInt(".threadpool_local_fs_reader_queue_size", 1000000); + auto pool_size = config.getUInt("threadpool_local_fs_reader_pool_size", 100); + auto queue_size = config.getUInt("threadpool_local_fs_reader_queue_size", 1000000); return std::make_unique(pool_size, queue_size); } case FilesystemReaderType::SYNCHRONOUS_LOCAL_FS_READER: