aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgvit <gvit@ydb.tech>2023-02-08 18:07:21 +0300
committergvit <gvit@ydb.tech>2023-02-08 18:07:21 +0300
commit5407272f4680720a634e9c23d0a37d1b9a8b2569 (patch)
tree01aaa55728a9a8a752ad51b596f6cd66595fe306
parent6f0623b4a43231d38c5761ff170fbdb6f796b741 (diff)
downloadydb-5407272f4680720a634e9c23d0a37d1b9a8b2569.tar.gz
fix tuple value
-rw-r--r--ydb/core/kqp/executer_actor/kqp_partition_helper.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/kqp/executer_actor/kqp_partition_helper.cpp b/ydb/core/kqp/executer_actor/kqp_partition_helper.cpp
index 95ad33773e..cf06397d15 100644
--- a/ydb/core/kqp/executer_actor/kqp_partition_helper.cpp
+++ b/ydb/core/kqp/executer_actor/kqp_partition_helper.cpp
@@ -228,9 +228,9 @@ TVector<TCell> FillKeyValues(const TVector<NScheme::TTypeInfo>& keyColumnTypes,
auto [type, value] = stageInfo.Meta.Tx.Params->GetParameterUnboxedValue(paramName);
if (paramIndex) {
YQL_ENSURE(type->GetKind() == NKikimr::NMiniKQL::TType::EKind::Tuple);
- auto actual = static_cast<NKikimr::NMiniKQL::TStructType*>(type);
- YQL_ENSURE(*paramIndex < actual->GetMembersCount());
- type = actual->GetMemberType(*paramIndex);
+ auto actual = static_cast<NKikimr::NMiniKQL::TTupleType*>(type);
+ YQL_ENSURE(*paramIndex < actual->GetElementsCount());
+ type = actual->GetElementType(*paramIndex);
value = value.GetElement(*paramIndex);
}