aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkomels <komels@ydb.tech>2022-11-02 15:50:46 +0300
committerkomels <komels@ydb.tech>2022-11-02 15:50:46 +0300
commite7b6303dfaa19ae40b8b8585110056a484367c07 (patch)
tree979dbc6686f6ff1bb977962f0906c18ec355f2a0
parentf52533dff57d75a49beeb8f07c7633155b420074 (diff)
downloadydb-e7b6303dfaa19ae40b8b8585110056a484367c07.tar.gz
Bug fix for PQ allocate
-rw-r--r--ydb/core/tx/schemeshard/schemeshard__operation_allocate_pq.cpp2
-rw-r--r--ydb/core/tx/schemeshard/schemeshard_path_describer.cpp1
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());