Skip to content

Commit

Permalink
Fixed build error in TForgetScriptExecutionOperationQueryActor
Browse files Browse the repository at this point in the history
  • Loading branch information
GrigoriyPA committed May 31, 2024
1 parent 459b977 commit 1e4f8d2
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions ydb/core/kqp/proxy_service/kqp_script_executions.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -820,7 +820,7 @@ class TCheckLeaseStatusActor : public TCheckLeaseStatusActorBase {
};

class TForgetScriptExecutionOperationQueryActor : public TQueryBase {
static constexpr i64 MAX_NUMBER_ROWS_IN_BATCH = 100000;
static constexpr i32 MAX_NUMBER_ROWS_IN_BATCH = 100000;

public:
TForgetScriptExecutionOperationQueryActor(const TString& executionId, const TString& database, TInstant operationDeadline)
Expand Down Expand Up @@ -877,12 +877,12 @@ class TForgetScriptExecutionOperationQueryActor : public TQueryBase {

result.TryNextRow();

TMaybe<i64> maxResultSetId = result.ColumnParser("max_result_set_id").GetOptionalInt32();
TMaybe<i32> maxResultSetId = result.ColumnParser("max_result_set_id").GetOptionalInt32();
if (!maxResultSetId) {
Finish();
return;
}
NumberRowsInBatch = std::max(MAX_NUMBER_ROWS_IN_BATCH / (*maxResultSetId + 1), 1l);
NumberRowsInBatch = std::max(MAX_NUMBER_ROWS_IN_BATCH / (*maxResultSetId + 1), 1);

TMaybe<i64> maxRowId = result.ColumnParser("max_row_id").GetOptionalInt64();
if (!maxRowId) {
Expand Down

0 comments on commit 1e4f8d2

Please sign in to comment.