diff --git a/ydb/core/kqp/proxy_service/kqp_script_executions.cpp b/ydb/core/kqp/proxy_service/kqp_script_executions.cpp index f9348b8d1089..011cda2cfd43 100644 --- a/ydb/core/kqp/proxy_service/kqp_script_executions.cpp +++ b/ydb/core/kqp/proxy_service/kqp_script_executions.cpp @@ -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) @@ -877,12 +877,12 @@ class TForgetScriptExecutionOperationQueryActor : public TQueryBase { result.TryNextRow(); - TMaybe maxResultSetId = result.ColumnParser("max_result_set_id").GetOptionalInt32(); + TMaybe 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 maxRowId = result.ColumnParser("max_row_id").GetOptionalInt64(); if (!maxRowId) {