aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authortesseract <tesseract@yandex-team.com>2023-03-28 17:11:43 +0300
committertesseract <tesseract@yandex-team.com>2023-03-28 17:11:43 +0300
commit8c60a8892fea1dac42c1860d1bee9750fb54c046 (patch)
tree21a4dfc974d41fa8ddf268d22c1a5e6e33a6d7dc
parent0e6ffae60c698b05a5d4d086260319c32b7a5568 (diff)
downloadydb-8c60a8892fea1dac42c1860d1bee9750fb54c046.tar.gz
Удалять из SS статистику удаленных топиков
-rw-r--r--ydb/core/tx/schemeshard/schemeshard_impl.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/ydb/core/tx/schemeshard/schemeshard_impl.cpp b/ydb/core/tx/schemeshard/schemeshard_impl.cpp
index 5aa4d5104a..f2d8653426 100644
--- a/ydb/core/tx/schemeshard/schemeshard_impl.cpp
+++ b/ydb/core/tx/schemeshard/schemeshard_impl.cpp
@@ -2512,6 +2512,7 @@ void TSchemeShard::PersistRemovePersQueueGroup(NIceDb::TNiceDb& db, TPathId path
}
db.Table<Schema::PersQueueGroups>().Key(pathId.LocalPathId).Delete();
+ db.Table<Schema::PersQueueGroupStats>().Key(pathId.LocalPathId).Delete();
}
void TSchemeShard::PersistAddPersQueueGroupAlter(NIceDb::TNiceDb& db, TPathId pathId, const TTopicInfo::TPtr alterData) {