Skip to content

Commit 477ff30

Browse files
authored
Fix input transform destructor (#7909)
1 parent 5523f7c commit 477ff30

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

ydb/library/yql/dq/actors/input_transforms/dq_input_transform_lookup.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,10 @@ class TInputTransformStreamLookupBase
8181
InitMonCounters(taskCounters);
8282
}
8383

84+
~TInputTransformStreamLookupBase() override {
85+
Free();
86+
}
87+
8488
void Bootstrap() {
8589
Become(&TInputTransformStreamLookupBase::StateFunc);
8690
NDq::IDqAsyncIoFactory::TLookupSourceArguments lookupSourceArgs {
@@ -192,6 +196,10 @@ class TInputTransformStreamLookupBase
192196

193197
void PassAway() final {
194198
Send(LookupSourceId, new NActors::TEvents::TEvPoison{});
199+
Free();
200+
}
201+
202+
void Free() {
195203
auto guard = BindAllocator();
196204
//All resources, held by this class, that have been created with mkql allocator, must be deallocated here
197205
KeysForLookup.reset();

0 commit comments

Comments
 (0)