From 6e94c9f617a5f821b9a22e762904cc92dab8ef01 Mon Sep 17 00:00:00 2001 From: kssenii Date: Thu, 12 Sep 2024 12:34:56 +0200 Subject: [PATCH] Fix --- src/Storages/ObjectStorageQueue/ObjectStorageQueueMetadata.cpp | 2 ++ .../ObjectStorageQueue/ObjectStorageQueueTableMetadata.cpp | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/Storages/ObjectStorageQueue/ObjectStorageQueueMetadata.cpp b/src/Storages/ObjectStorageQueue/ObjectStorageQueueMetadata.cpp index e424769b061..2da4aa6b665 100644 --- a/src/Storages/ObjectStorageQueue/ObjectStorageQueueMetadata.cpp +++ b/src/Storages/ObjectStorageQueue/ObjectStorageQueueMetadata.cpp @@ -239,6 +239,8 @@ void ObjectStorageQueueMetadata::syncWithKeeper( const auto metadata_str = zookeeper->get(fs::path(zookeeper_path) / "metadata"); const auto metadata_from_zk = ObjectStorageQueueTableMetadata::parse(metadata_str); + LOG_TRACE(log, "Metadata in keeper: {}", metadata_str); + table_metadata.checkEquals(metadata_from_zk); return; } diff --git a/src/Storages/ObjectStorageQueue/ObjectStorageQueueTableMetadata.cpp b/src/Storages/ObjectStorageQueue/ObjectStorageQueueTableMetadata.cpp index c2f70e3e804..926d5aacda4 100644 --- a/src/Storages/ObjectStorageQueue/ObjectStorageQueueTableMetadata.cpp +++ b/src/Storages/ObjectStorageQueue/ObjectStorageQueueTableMetadata.cpp @@ -88,7 +88,7 @@ ObjectStorageQueueTableMetadata::ObjectStorageQueueTableMetadata(const Poco::JSO , tracked_files_limit(getOrDefault(json, "tracked_files_limit", "s3queue_", 0)) , tracked_file_ttl_sec(getOrDefault(json, "tracked_files_ttl_sec", "s3queue_", 0)) , buckets(getOrDefault(json, "buckets", "", 0)) - , processing_threads_num(getOrDefault(json, "processing_threads_num", "s3queue_", 0)) + , processing_threads_num(getOrDefault(json, "processing_threads_num", "s3queue_", 1)) , last_processed_path(getOrDefault(json, "last_processed_file", "s3queue_", "")) { }