aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorPisarenko Grigoriy <79596613+GrigoriyPA@users.noreply.github.com>2024-06-01 00:51:19 +0300
committerGitHub <noreply@github.com>2024-06-01 00:51:19 +0300
commit97fc7f08ad45df7e01d9ae5012b45e077ff1f2f7 (patch)
tree93ce669d40aedef825803c7f936ab2d2a3947d0a
parentbd28e29effe1679335f55422998a17328f7570c3 (diff)
downloadydb-97fc7f08ad45df7e01d9ae5012b45e077ff1f2f7.tar.gz
Fixed build error in TForgetScriptExecutionOperationQueryActor (#5084)
-rw-r--r--ydb/core/kqp/proxy_service/kqp_script_executions.cpp6
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) {