File tree Expand file tree Collapse file tree 1 file changed +0
-6
lines changed
ydb/core/fq/libs/row_dispatcher Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change @@ -149,10 +149,6 @@ class TFilterInputConsumer : public NYql::NPureCalc::IConsumer<std::pair<const T
149
149
150
150
Worker->Push (std::move (result));
151
151
}
152
-
153
- // Clear cache after on each object because
154
- // values allocated on another allocator and should be released
155
- Cache.Clear ();
156
152
}
157
153
}
158
154
@@ -271,8 +267,6 @@ class TJsonFilter::TImpl {
271
267
NYql::NPureCalc::TProgramFactoryOptions ().SetScopedAlloc (std::move (alloc))
272
268
);
273
269
274
- // Program should be stateless because input values
275
- // allocated on another allocator and should be released
276
270
LOG_ROW_DISPATCHER_DEBUG (" Creating program..." );
277
271
Program = factory->MakePushStreamProgram (
278
272
TFilterInputSpec (MakeInputSchema (columns, types)),
You can’t perform that action at this time.
0 commit comments