File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
ydb/core/kqp/proxy_service Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -820,7 +820,7 @@ class TCheckLeaseStatusActor : public TCheckLeaseStatusActorBase {
820
820
};
821
821
822
822
class TForgetScriptExecutionOperationQueryActor : public TQueryBase {
823
- static constexpr i64 MAX_NUMBER_ROWS_IN_BATCH = 100000 ;
823
+ static constexpr i32 MAX_NUMBER_ROWS_IN_BATCH = 100000 ;
824
824
825
825
public:
826
826
TForgetScriptExecutionOperationQueryActor (const TString& executionId, const TString& database, TInstant operationDeadline)
@@ -877,12 +877,12 @@ class TForgetScriptExecutionOperationQueryActor : public TQueryBase {
877
877
878
878
result.TryNextRow ();
879
879
880
- TMaybe<i64 > maxResultSetId = result.ColumnParser (" max_result_set_id" ).GetOptionalInt32 ();
880
+ TMaybe<i32 > maxResultSetId = result.ColumnParser (" max_result_set_id" ).GetOptionalInt32 ();
881
881
if (!maxResultSetId) {
882
882
Finish ();
883
883
return ;
884
884
}
885
- NumberRowsInBatch = std::max (MAX_NUMBER_ROWS_IN_BATCH / (*maxResultSetId + 1 ), 1l );
885
+ NumberRowsInBatch = std::max (MAX_NUMBER_ROWS_IN_BATCH / (*maxResultSetId + 1 ), 1 );
886
886
887
887
TMaybe<i64 > maxRowId = result.ColumnParser (" max_row_id" ).GetOptionalInt64 ();
888
888
if (!maxRowId) {
You can’t perform that action at this time.
0 commit comments