[yql] Proper Rewind for exec transformers

1 files changed, 8 insertions, 0 deletions

diff --git a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
index a34f88df2d2..c03c0e4f9ce 100644
--- a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
+++ b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
@@ -253,6 +253,14 @@ public:
         AddHandler({TDqQuery::CallableName()}, RequireFirst(), Pass());
     }
 
+    void Rewind() override {
+        ExecState = MakeIntrusive<TExecState>();
+        FileLinks.clear();
+        ModulesMapping.clear();
+
+        TExecTransformerBase::Rewind();
+    }
+
 private:
     struct TExecState : public TThrRefBase {
         TAdaptiveLock Lock;