diff options
author | komels <komels@ydb.tech> | 2022-11-02 15:50:46 +0300 |
---|---|---|
committer | komels <komels@ydb.tech> | 2022-11-02 15:50:46 +0300 |
commit | e7b6303dfaa19ae40b8b8585110056a484367c07 (patch) | |
tree | 979dbc6686f6ff1bb977962f0906c18ec355f2a0 | |
parent | f52533dff57d75a49beeb8f07c7633155b420074 (diff) | |
download | ydb-e7b6303dfaa19ae40b8b8585110056a484367c07.tar.gz |
Bug fix for PQ allocate
-rw-r--r-- | ydb/core/tx/schemeshard/schemeshard__operation_allocate_pq.cpp | 2 | ||||
-rw-r--r-- | ydb/core/tx/schemeshard/schemeshard_path_describer.cpp | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_allocate_pq.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_allocate_pq.cpp index 8115899476e..b5474675c84 100644 --- a/ydb/core/tx/schemeshard/schemeshard__operation_allocate_pq.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__operation_allocate_pq.cpp @@ -196,7 +196,7 @@ public: return result; } - pqGroupInfo->AlterVersion = allocateDesc.GetAlterVersion() + 1; + pqGroupInfo->AlterVersion = allocateDesc.GetAlterVersion(); if (!allocateDesc.HasPQTabletConfig()) { auto errStr = TStringBuilder() << "No PQTabletConfig specified"; diff --git a/ydb/core/tx/schemeshard/schemeshard_path_describer.cpp b/ydb/core/tx/schemeshard/schemeshard_path_describer.cpp index e6d00f97dac..80c6c09bf39 100644 --- a/ydb/core/tx/schemeshard/schemeshard_path_describer.cpp +++ b/ydb/core/tx/schemeshard/schemeshard_path_describer.cpp @@ -486,6 +486,7 @@ void TPathDescriber::DescribePersQueueGroup(TPathId pathId, TPathElement::TPtr p } } } + allocate->SetAlterVersion(pqGroupInfo->AlterVersion); } Y_VERIFY_DEBUG(!Result->PreSerializedData.empty()); |