From f83f155a14aba15db257ec9aa97c77fd4d91cca8 Mon Sep 17 00:00:00 2001 From: Arthur Passos Date: Tue, 10 Mar 2026 09:42:33 -0300 Subject: [PATCH 1/3] bump scheduled exports count only once it has been scheduled --- src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp b/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp index 89042fe694b9..46db7f6c02a3 100644 --- a/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp +++ b/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp @@ -266,6 +266,8 @@ void ExportPartitionTaskScheduler::run() { handlePartExportCompletion(key, zk_part_name, manifest, destination_storage, result); }); + + scheduled_exports_count++; } catch (const Exception &) { @@ -277,7 +279,6 @@ void ExportPartitionTaskScheduler::run() } } - scheduled_exports_count++; } } } From 35a4d960cccf0b1740f71f053e504ce0f318e4de Mon Sep 17 00:00:00 2001 From: Arthur Passos Date: Mon, 16 Mar 2026 10:41:40 -0300 Subject: [PATCH 2/3] missing increment --- src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp b/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp index 46db7f6c02a3..9f18bb4e4ab8 100644 --- a/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp +++ b/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp @@ -236,6 +236,8 @@ void ExportPartitionTaskScheduler::run() LOG_INFO(storage.log, "ExportPartition scheduler task: Failed to schedule export part task, skipping"); return; } + + scheduled_exports_count++ } else { From deac1248536507eb2b9ac798e1c9df2ea16f7560 Mon Sep 17 00:00:00 2001 From: Arthur Passos Date: Mon, 16 Mar 2026 11:22:32 -0300 Subject: [PATCH 3/3] oh boy --- src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp b/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp index 9f18bb4e4ab8..00f6d8687f93 100644 --- a/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp +++ b/src/Storages/MergeTree/ExportPartitionTaskScheduler.cpp @@ -237,7 +237,7 @@ void ExportPartitionTaskScheduler::run() return; } - scheduled_exports_count++ + scheduled_exports_count++; } else {