diff options
| -rw-r--r-- | ydb/core/kqp/proxy_service/kqp_script_executions.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/kqp/proxy_service/kqp_script_executions.cpp b/ydb/core/kqp/proxy_service/kqp_script_executions.cpp index f9348b8d108..011cda2cfd4 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 @@ private: }; 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 @@ public: 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) { |