aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorulya-sidorina <yulia@ydb.tech>2022-12-08 20:59:23 +0300
committerulya-sidorina <yulia@ydb.tech>2022-12-08 20:59:23 +0300
commit96b5ab9295df718b2f695b3ee1223d407d3de565 (patch)
tree7ac7f2b68cc2507c55c432b1e68e4c21cce1b7c0
parent960c46a34e102e33a8cd99b01068822e91eb36c1 (diff)
downloadydb-96b5ab9295df718b2f695b3ee1223d407d3de565.tar.gz
fix TKqpBuildTxsTransformer
fix(kqp): keep QueryResults as TKqpBuildTxsTransformer member
-rw-r--r--ydb/core/kqp/opt/kqp_opt_build_txs.cpp6
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