diff options
| author | andrew stalin <andrew.stalin@gmail.com> | 2024-08-29 17:38:24 +0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-29 10:38:24 +0000 |
| commit | 3a914af704d942b638c72f314501a97e4a196e47 (patch) | |
| tree | a18b9b6cd729f854ba065f0a3062b1eb898bdb50 | |
| parent | 02dbcf2e6d1a2812780b0ec28f30b5a1ca86aed0 (diff) | |
| download | ydb-3a914af704d942b638c72f314501a97e4a196e47.tar.gz | |
Reset traversal for tables with TraversalStarted status (#8441)
| -rw-r--r-- | ydb/core/statistics/aggregator/tx_init.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/core/statistics/aggregator/tx_init.cpp b/ydb/core/statistics/aggregator/tx_init.cpp index 502e161d56..ae8a8a355e 100644 --- a/ydb/core/statistics/aggregator/tx_init.cpp +++ b/ydb/core/statistics/aggregator/tx_init.cpp @@ -236,6 +236,9 @@ struct TStatisticsAggregator::TTxInit : public TTxBase { if (status == TForceTraversalTable::EStatus::AnalyzeStarted) { // Resent TEvAnalyzeTable to shards status = TForceTraversalTable::EStatus::None; + } else if (status == TForceTraversalTable::EStatus::TraversalStarted) { + // Reset traversal + status = TForceTraversalTable::EStatus::AnalyzeFinished; } auto pathId = TPathId(ownerId, localPathId); |