fix build after merge

ydb-platform · Dec 4, 2024 · 803c079 · 803c079
1 parent 6a01338
commit 803c079
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/ydb/core/fq/libs/row_dispatcher/row_dispatcher.cpp b/ydb/core/fq/libs/row_dispatcher/row_dispatcher.cpp
@@ -731,6 +731,7 @@ void TRowDispatcher::Handle(NFq::TEvRowDispatcher::TEvStartSession::TPtr& ev) {
                 source.GetDatabase(),
                 Config,
                 SelfId(),
+                CompileServiceActorId,
                 partitionId,
                 YqSharedResources->UserSpaceYdbDriver,
                 CreateCredentialsProviderFactoryForStructuredToken(

diff --git a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp
@@ -803,8 +803,10 @@ bool HasJsonColumns(const NYql::NPq::NProto::TDqPqTopicSource& sourceParams) {
 
 void TTopicSession::StartClientSession(TClientsInfo& info) {
     if (ReadSession) {
-        if (info.Settings.HasOffset() && info.Settings.GetOffset() <= LastMessageOffset) {
-            LOG_ROW_DISPATCHER_INFO("New client has less offset (" << info.Settings.GetOffset() << ") than the last message (" << LastMessageOffset << "), stop (restart) topic session");
+        auto offset = GetOffset(info.Settings);
+
+        if (offset && (offset <= LastMessageOffset)) {
+            LOG_ROW_DISPATCHER_INFO("New client has less offset (" << offset << ") than the last message (" << LastMessageOffset << "), stop (restart) topic session");
             Metrics.RestartSessionByOffsets->Inc();
             ++RestartSessionByOffsets;
             info.RestartSessionByOffsetsByQuery->Inc();