diff options
author | ulya-sidorina <yulia@ydb.tech> | 2022-12-08 20:59:23 +0300 |
---|---|---|
committer | ulya-sidorina <yulia@ydb.tech> | 2022-12-08 20:59:23 +0300 |
commit | 96b5ab9295df718b2f695b3ee1223d407d3de565 (patch) | |
tree | 7ac7f2b68cc2507c55c432b1e68e4c21cce1b7c0 | |
parent | 960c46a34e102e33a8cd99b01068822e91eb36c1 (diff) | |
download | ydb-96b5ab9295df718b2f695b3ee1223d407d3de565.tar.gz |
fix TKqpBuildTxsTransformer
fix(kqp): keep QueryResults as TKqpBuildTxsTransformer member
-rw-r--r-- | ydb/core/kqp/opt/kqp_opt_build_txs.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/kqp/opt/kqp_opt_build_txs.cpp b/ydb/core/kqp/opt/kqp_opt_build_txs.cpp index 922d2ca1de..626aa75021 100644 --- a/ydb/core/kqp/opt/kqp_opt_build_txs.cpp +++ b/ydb/core/kqp/opt/kqp_opt_build_txs.cpp @@ -475,7 +475,6 @@ public: YQL_CLOG(DEBUG, ProviderKqp) << ">>> TKqpBuildTxsTransformer: " << KqpExprToPrettyString(*inputExpr, ctx); TKqlQuery query(inputExpr); - TVector<TExprBase> queryResults; for (; CurrentQueryBlockId < query.Blocks().Size(); ++CurrentQueryBlockId) { const auto& block = query.Blocks().Item(CurrentQueryBlockId); @@ -501,7 +500,7 @@ public: .Build(ToString(i)) .Done(); - queryResults.emplace_back(std::move(binding)); + QueryResults.emplace_back(std::move(binding)); } } @@ -540,7 +539,7 @@ public: .Add(BuildCtx->PhysicalTxs) .Build() .Results() - .Add(queryResults) + .Add(QueryResults) .Build() .Settings(querySettings.BuildNode(ctx, query.Pos())) .Done(); @@ -755,6 +754,7 @@ private: TAutoPtr<IGraphTransformer> DataTxTransformer; TAutoPtr<IGraphTransformer> ScanTxTransformer; ui32 CurrentQueryBlockId = 0; + TVector<TExprBase> QueryResults; }; } // namespace |