diff --git a/be/src/vec/aggregate_functions/aggregate_function_approx_top_k.h b/be/src/vec/aggregate_functions/aggregate_function_approx_top_k.h index 6a9b1636fa0d94..2111c4dcd8f46c 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_approx_top_k.h +++ b/be/src/vec/aggregate_functions/aggregate_function_approx_top_k.h @@ -85,7 +85,7 @@ class AggregateFunctionApproxTopK final void deserialize(AggregateDataPtr __restrict place, BufferReadable& buf, Arena* arena) const override { auto readStringBinaryInto = [](Arena& arena, BufferReadable& buf) { - size_t size = 0; + UInt64 size = 0; read_var_uint(size, buf); if (UNLIKELY(size > DEFAULT_MAX_STRING_SIZE)) { @@ -101,7 +101,7 @@ class AggregateFunctionApproxTopK final auto& set = this->data(place).value; set.clear(); - size_t size = 0; + UInt64 size = 0; read_var_uint(size, buf); if (UNLIKELY(size > TOP_K_MAX_SIZE)) { throw Exception(ErrorCode::INTERNAL_ERROR, diff --git a/be/src/vec/aggregate_functions/aggregate_function_collect.h b/be/src/vec/aggregate_functions/aggregate_function_collect.h index 02490be56a0bf1..f4c0bf4f2fed07 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_collect.h +++ b/be/src/vec/aggregate_functions/aggregate_function_collect.h @@ -98,7 +98,7 @@ struct AggregateFunctionCollectSetData { } void read(BufferReadable& buf) { - size_t new_size = 0; + UInt64 new_size = 0; read_var_uint(new_size, buf); ElementNativeType x; for (size_t i = 0; i < new_size; ++i) { diff --git a/be/src/vec/aggregate_functions/aggregate_function_distinct.h b/be/src/vec/aggregate_functions/aggregate_function_distinct.h index 3cce558312be24..4149fb08d706af 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_distinct.h +++ b/be/src/vec/aggregate_functions/aggregate_function_distinct.h @@ -94,7 +94,7 @@ struct AggregateFunctionDistinctSingleNumericData { void deserialize(BufferReadable& buf, Arena*) { DCHECK(!stable); if constexpr (!stable) { - size_t new_size = 0; + UInt64 new_size = 0; read_var_uint(new_size, buf); T x; for (size_t i = 0; i < new_size; ++i) { diff --git a/be/src/vec/common/space_saving.h b/be/src/vec/common/space_saving.h index 18fa216228ddfb..06e1bdcbc2bf79 100644 --- a/be/src/vec/common/space_saving.h +++ b/be/src/vec/common/space_saving.h @@ -244,7 +244,7 @@ class SpaceSaving { void read(BufferReadable& rb) { destroy_elements(); - size_t count = 0; + UInt64 count = 0; read_var_uint(count, rb); for (size_t i = 0; i < count; ++i) { @@ -259,7 +259,7 @@ class SpaceSaving { // Reads the alpha map data from the provided readable buffer. void read_alpha_map(BufferReadable& rb) { - size_t alpha_size = 0; + UInt64 alpha_size = 0; read_var_uint(alpha_size, rb); for (size_t i = 0; i < alpha_size; ++i) { uint64_t alpha = 0; diff --git a/be/src/vec/exprs/table_function/vexplode_numbers.cpp b/be/src/vec/exprs/table_function/vexplode_numbers.cpp index 0c4c330f73c787..b838563cc9f207 100644 --- a/be/src/vec/exprs/table_function/vexplode_numbers.cpp +++ b/be/src/vec/exprs/table_function/vexplode_numbers.cpp @@ -70,7 +70,7 @@ Status VExplodeNumbersTableFunction::process_init(Block* block, RuntimeState* st ((ColumnInt32*)_elements_column.get())->clear(); //_cur_size may be a negative number - _cur_size = std::max(0L, _cur_size); + _cur_size = std::max(static_cast(0), _cur_size); if (_cur_size && _cur_size <= state->batch_size()) { // avoid elements_column too big or empty _is_const = true; // use const optimize diff --git a/be/src/vec/exprs/vruntimefilter_wrapper.h b/be/src/vec/exprs/vruntimefilter_wrapper.h index 79e9361e854719..4c7ea8b162dc76 100644 --- a/be/src/vec/exprs/vruntimefilter_wrapper.h +++ b/be/src/vec/exprs/vruntimefilter_wrapper.h @@ -77,7 +77,9 @@ class VRuntimeFilterWrapper final : public VExpr { template static void judge_selectivity(double ignore_threshold, int64_t filter_rows, int64_t input_rows, T& always_true) { - always_true = filter_rows / (input_rows * 1.0L) < ignore_threshold; + always_true = static_cast(filter_rows) / + (static_cast(input_rows) * 1.0L) < + ignore_threshold; } bool is_rf_wrapper() const override { return true; }