diff options
author | gvit <gvit@ydb.tech> | 2023-02-08 18:07:21 +0300 |
---|---|---|
committer | gvit <gvit@ydb.tech> | 2023-02-08 18:07:21 +0300 |
commit | 5407272f4680720a634e9c23d0a37d1b9a8b2569 (patch) | |
tree | 01aaa55728a9a8a752ad51b596f6cd66595fe306 | |
parent | 6f0623b4a43231d38c5761ff170fbdb6f796b741 (diff) | |
download | ydb-5407272f4680720a634e9c23d0a37d1b9a8b2569.tar.gz |
fix tuple value
-rw-r--r-- | ydb/core/kqp/executer_actor/kqp_partition_helper.cpp | 6 |
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); } |