thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Minor

Browse Source
This commit is contained in:
kssenii 2024-09-18 14:11:33 +02:00
parent 8005fa4a74
commit ff92c4942d
3 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Storages/ObjectStorageQueue/ObjectStorageQueueMetadata.cpp
View File

@ -256,12 +256,7 @@ ObjectStorageQueueTableMetadata ObjectStorageQueueMetadata::syncWithKeeper(
LOG_TRACE(log, "Metadata in keeper: {}", metadata_str);
if (table_metadata.adjustFromKeeper(metadata_from_zk))
{
LOG_TRACE(log, "Using `processing_threads_num` from keeper: {} (local: {})",
table_metadata.processing_threads_num, settings.processing_threads_num);
}
table_metadata.adjustFromKeeper(metadata_from_zk);
table_metadata.checkEquals(metadata_from_zk);
return table_metadata;
}

8
src/Storages/ObjectStorageQueue/ObjectStorageQueueTableMetadata.cpp
View File

@ -116,14 +116,16 @@ ObjectStorageQueueTableMetadata ObjectStorageQueueTableMetadata::parse(const Str
return ObjectStorageQueueTableMetadata(json);
}
bool ObjectStorageQueueTableMetadata::adjustFromKeeper(const ObjectStorageQueueTableMetadata & from_zk)
void ObjectStorageQueueTableMetadata::adjustFromKeeper(const ObjectStorageQueueTableMetadata & from_zk)
{
if (processing_threads_num != from_zk.processing_threads_num)
{
LOG_TRACE(getLogger("ObjectStorageQueueTableMetadata"),
"Using `processing_threads_num` from keeper: {} (local: {})",
from_zk.processing_threads_num, processing_threads_num);
processing_threads_num = from_zk.processing_threads_num;
return true;
}
return false;
}
void ObjectStorageQueueTableMetadata::checkEquals(const ObjectStorageQueueTableMetadata & from_zk) const

2
src/Storages/ObjectStorageQueue/ObjectStorageQueueTableMetadata.h
View File

@ -42,7 +42,7 @@ struct ObjectStorageQueueTableMetadata
ObjectStorageQueueMode getMode() const;
bool adjustFromKeeper(const ObjectStorageQueueTableMetadata & from_zk);
void adjustFromKeeper(const ObjectStorageQueueTableMetadata & from_zk);
void checkEquals(const ObjectStorageQueueTableMetadata & from_zk) const;