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_", "")) { }