Fixed build

GrigoriyPA · GrigoriyPA · commit 9da66ef411f7 · 2024-11-14T18:10:59.000Z
diff --git a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp
@@ -639,7 +639,7 @@ void TTopicSession::DoFiltering(ui64 rowsOffset, ui64 numberRows, const TVector<
     for (auto& [actorId, info] : Clients) {
         try {
             if (info.Filter) {
-                info.Filter->Push(offsets, RebuildJson(info, parsedValues));
+                info.Filter->Push(offsets, RebuildJson(info, parsedValues), rowsOffset, numberRows);
             }
         } catch (const std::exception& e) {
             FatalError(e.what(), &info.Filter, false);

Original file line number	Diff line number	Diff line change
`@@ -639,7 +639,7 @@ void TTopicSession::DoFiltering(ui64 rowsOffset, ui64 numberRows, const TVector<`
`639`	`639`	`for (auto& [actorId, info] : Clients) {`
`640`	`640`	`try {`
`641`	`641`	`if (info.Filter) {`
`642`		`- info.Filter->Push(offsets, RebuildJson(info, parsedValues));`
	`642`	`+ info.Filter->Push(offsets, RebuildJson(info, parsedValues), rowsOffset, numberRows);`
`643`	`643`	`}`
`644`	`644`	`} catch (const std::exception& e) {`
`645`	`645`	`FatalError(e.what(), &info.Filter, false);`