Skip to content

Commit f94d002

Browse files
committed
fix kqp_query_data
1 parent 0d46fcf commit f94d002

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

ydb/core/kqp/query_data/kqp_query_data.cpp

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,17 +117,19 @@ void TKqpExecuterTxResult::FillYdb(Ydb::ResultSet* ydbResult, TMaybe<ui64> rowsL
117117

118118
TTxAllocatorState::TTxAllocatorState(const IFunctionRegistry* functionRegistry,
119119
TIntrusivePtr<ITimeProvider> timeProvider, TIntrusivePtr<IRandomProvider> randomProvider)
120-
: Alloc(std::make_shared<NKikimr::NMiniKQL::TScopedAlloc>(__LOCATION__, NKikimr::TAlignedPagePoolCounters(), functionRegistry->SupportsSizedAllocators(), false))
120+
: Alloc(std::make_shared<NKikimr::NMiniKQL::TScopedAlloc>(__LOCATION__, NKikimr::TAlignedPagePoolCounters(), functionRegistry->SupportsSizedAllocators()))
121121
, TypeEnv(*Alloc)
122122
, MemInfo("TQueryData")
123123
, HolderFactory(Alloc->Ref(), MemInfo, functionRegistry)
124124
{
125+
Alloc->Release();
125126
TimeProvider = timeProvider;
126127
RandomProvider = randomProvider;
127128
}
128129

129130
TTxAllocatorState::~TTxAllocatorState()
130131
{
132+
Alloc->Acquire();
131133
}
132134

133135
std::pair<NKikimr::NMiniKQL::TType*, NUdf::TUnboxedValue> TTxAllocatorState::GetInternalBindingValue(

0 commit comments

Comments
 (0)