diff options
| author | nsofya <nsofya@ydb.tech> | 2023-12-10 16:50:04 +0300 |
|---|---|---|
| committer | nsofya <nsofya@ydb.tech> | 2023-12-10 17:09:58 +0300 |
| commit | ecea7143acf5b9c30c9b68b471cf9a468d9b5db5 (patch) | |
| tree | d71d95f85346a4c64045e4aae3f168b1b6178a4e | |
| parent | 373052f21d8ee25dceb85dc08992de6b0c143857 (diff) | |
| download | ydb-ecea7143acf5b9c30c9b68b471cf9a468d9b5db5.tar.gz | |
KIKIMR-20422: Remove schema versions
| -rw-r--r-- | ydb/core/tx/columnshard/tables_manager.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/ydb/core/tx/columnshard/tables_manager.cpp b/ydb/core/tx/columnshard/tables_manager.cpp index e5fa43997d..ee9222a40c 100644 --- a/ydb/core/tx/columnshard/tables_manager.cpp +++ b/ydb/core/tx/columnshard/tables_manager.cpp @@ -317,6 +317,11 @@ bool TTablesManager::TryFinalizeDropPath(NTabletFlatExecutor::TTransactionContex PathsToDrop.erase(itDrop); NIceDb::TNiceDb db(txc.DB); NColumnShard::Schema::EraseTableInfo(db, pathId); + const auto& table = Tables.find(pathId); + Y_ABORT_UNLESS(table != Tables.end(), "No schema for path %lu", pathId); + for (auto&& tableVersion : table->second.GetVersions()) { + NColumnShard::Schema::EraseTableVersionInfo(db, pathId, tableVersion.first); + } return true; } |