Skip to content

Commit e98c40c

Browse files
authored
Merge caf64cf into b3c26e4
2 parents b3c26e4 + caf64cf commit e98c40c

File tree

3 files changed

+5
-2
lines changed

3 files changed

+5
-2
lines changed

ydb/core/fq/libs/compute/ydb/events/events.h

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,15 +147,17 @@ struct TEvYdbCompute {
147147
};
148148

149149
struct TEvFetchScriptResultRequest : public NActors::TEventLocal<TEvFetchScriptResultRequest, EvFetchScriptResultRequest> {
150-
TEvFetchScriptResultRequest(const NKikimr::NOperationId::TOperationId& operationId, int64_t resultSetId, const TString& fetchToken)
150+
TEvFetchScriptResultRequest(const NKikimr::NOperationId::TOperationId& operationId, int64_t resultSetId, const TString& fetchToken, uint64_t rowsLimit)
151151
: OperationId(operationId)
152152
, ResultSetId(resultSetId)
153153
, FetchToken(fetchToken)
154+
, RowsLimit(rowsLimit)
154155
{}
155156

156157
NKikimr::NOperationId::TOperationId OperationId;
157158
int64_t ResultSetId = 0;
158159
TString FetchToken;
160+
uint64_t RowsLimit = 0;
159161
};
160162

161163
struct TEvFetchScriptResultResponse : public NActors::TEventLocal<TEvFetchScriptResultResponse, EvFetchScriptResultResponse> {

ydb/core/fq/libs/compute/ydb/result_writer_actor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ class TResultSetWriterActor : public TBaseComputeActor<TResultSetWriterActor> {
190190

191191
void SendFetchScriptResultRequest() {
192192
LastProcessedToken = FetchToken;
193-
Register(new TRetryActor<TEvYdbCompute::TEvFetchScriptResultRequest, TEvYdbCompute::TEvFetchScriptResultResponse, NKikimr::NOperationId::TOperationId, int64_t, TString>(Counters.GetCounters(ERequestType::RT_FETCH_SCRIPT_RESULT), SelfId(), Connector, OperationId, ResultSetId, FetchToken));
193+
Register(new TRetryActor<TEvYdbCompute::TEvFetchScriptResultRequest, TEvYdbCompute::TEvFetchScriptResultResponse, NKikimr::NOperationId::TOperationId, int64_t, TString, uint64_t>(Counters.GetCounters(ERequestType::RT_FETCH_SCRIPT_RESULT), SelfId(), Connector, OperationId, ResultSetId, FetchToken, 0));
194194
}
195195

196196
void SendReplyAndPassAway() {

ydb/core/fq/libs/compute/ydb/ydb_connector_actor.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,7 @@ class TYdbConnectorActor : public NActors::TActorBootstrapped<TYdbConnectorActor
130130
void Handle(const TEvYdbCompute::TEvFetchScriptResultRequest::TPtr& ev) {
131131
NYdb::NQuery::TFetchScriptResultsSettings settings;
132132
settings.FetchToken(ev->Get()->FetchToken);
133+
settings.RowsLimit(ev->Get()->RowsLimit);
133134
QueryClient
134135
->FetchScriptResults(ev->Get()->OperationId, ev->Get()->ResultSetId, settings)
135136
.Apply([actorSystem = NActors::TActivationContext::ActorSystem(), recipient = ev->Sender, cookie = ev->Cookie, database = ComputeConnection.database()](auto future) {

0 commit comments

Comments
 (0)