diff --git a/be/src/vec/spill/spill_reader.cpp b/be/src/vec/spill/spill_reader.cpp index f0320ee9b490bb..3c2f00273a4b5d 100644 --- a/be/src/vec/spill/spill_reader.cpp +++ b/be/src/vec/spill/spill_reader.cpp @@ -19,6 +19,7 @@ #include +#include "common/cast_set.h" #include "common/exception.h" #include "io/file_factory.h" #include "io/fs/file_reader.h" @@ -27,6 +28,7 @@ #include "util/slice.h" #include "vec/core/block.h" namespace doris { +#include "common/compile_check_begin.h" namespace io { class FileSystem; } // namespace io @@ -113,7 +115,7 @@ Status SpillReader::read(Block* block, bool* eos) { if (bytes_read > 0) { { SCOPED_TIMER(deserialize_timer_); - if (!pb_block_.ParseFromArray(result.data, result.size)) { + if (!pb_block_.ParseFromArray(result.data, cast_set(result.size))) { return Status::InternalError("Failed to read spilled block"); } RETURN_IF_ERROR(block->deserialize(pb_block_)); diff --git a/be/src/vec/spill/spill_reader.h b/be/src/vec/spill/spill_reader.h index 6694bf91572e7c..6dea8376206df9 100644 --- a/be/src/vec/spill/spill_reader.h +++ b/be/src/vec/spill/spill_reader.h @@ -28,6 +28,7 @@ #include "util/runtime_profile.h" namespace doris::vectorized { +#include "common/compile_check_begin.h" class Block; class SpillReader { public: @@ -78,4 +79,5 @@ class SpillReader { using SpillReaderUPtr = std::unique_ptr; -} // namespace doris::vectorized \ No newline at end of file +} // namespace doris::vectorized +#include "common/compile_check_end.h" diff --git a/be/src/vec/spill/spill_stream.cpp b/be/src/vec/spill/spill_stream.cpp index 7189fad262c465..d83cbabb1893d9 100644 --- a/be/src/vec/spill/spill_stream.cpp +++ b/be/src/vec/spill/spill_stream.cpp @@ -34,6 +34,7 @@ #include "vec/spill/spill_writer.h" namespace doris::vectorized { +#include "common/compile_check_begin.h" SpillStream::SpillStream(RuntimeState* state, int64_t stream_id, SpillDataDir* data_dir, std::string spill_dir, size_t batch_rows, size_t batch_bytes, RuntimeProfile* profile) diff --git a/be/src/vec/spill/spill_stream.h b/be/src/vec/spill/spill_stream.h index ad30a0bbd1d21b..a95a4760322703 100644 --- a/be/src/vec/spill/spill_stream.h +++ b/be/src/vec/spill/spill_stream.h @@ -24,6 +24,7 @@ #include "vec/spill/spill_writer.h" namespace doris { +#include "common/compile_check_begin.h" class RuntimeProfile; class ThreadPool; @@ -109,4 +110,5 @@ class SpillStream { }; using SpillStreamSPtr = std::shared_ptr; } // namespace vectorized -} // namespace doris \ No newline at end of file +} // namespace doris +#include "common/compile_check_end.h" diff --git a/be/src/vec/spill/spill_stream_manager.cpp b/be/src/vec/spill/spill_stream_manager.cpp index 61e96559d23628..89bd09b7fadd06 100644 --- a/be/src/vec/spill/spill_stream_manager.cpp +++ b/be/src/vec/spill/spill_stream_manager.cpp @@ -41,6 +41,7 @@ #include "vec/spill/spill_stream.h" namespace doris::vectorized { +#include "common/compile_check_begin.h" SpillStreamManager::SpillStreamManager( std::unordered_map>&& @@ -350,8 +351,8 @@ Status SpillDataDir::update_capacity() { &_available_bytes)); spill_disk_capacity->set_value(_disk_capacity_bytes); spill_disk_avail_capacity->set_value(_available_bytes); - auto disk_use_max_bytes = (int64_t)(_disk_capacity_bytes * - config::storage_flood_stage_usage_percent / (double)100); + auto disk_use_max_bytes = + (int64_t)(_disk_capacity_bytes * config::storage_flood_stage_usage_percent / 100); bool is_percent = true; _spill_data_limit_bytes = ParseUtil::parse_mem_spec(config::spill_storage_limit, -1, _disk_capacity_bytes, &is_percent); @@ -363,9 +364,8 @@ Status SpillDataDir::update_capacity() { return Status::InvalidArgument(err_msg); } if (is_percent) { - _spill_data_limit_bytes = - (int64_t)(_spill_data_limit_bytes * config::storage_flood_stage_usage_percent / - (double)100); + _spill_data_limit_bytes = (int64_t)(_spill_data_limit_bytes * + config::storage_flood_stage_usage_percent / 100); } if (_spill_data_limit_bytes > disk_use_max_bytes) { _spill_data_limit_bytes = disk_use_max_bytes; diff --git a/be/src/vec/spill/spill_stream_manager.h b/be/src/vec/spill/spill_stream_manager.h index 66c71724f162fe..7bcfe9500979b9 100644 --- a/be/src/vec/spill/spill_stream_manager.h +++ b/be/src/vec/spill/spill_stream_manager.h @@ -28,6 +28,7 @@ #include "util/threadpool.h" #include "vec/spill/spill_stream.h" namespace doris { +#include "common/compile_check_begin.h" class RuntimeProfile; namespace vectorized { @@ -77,7 +78,7 @@ class SpillDataDir { double _get_disk_usage(int64_t incoming_data_size) const { return _disk_capacity_bytes == 0 ? 0 - : (_disk_capacity_bytes - _available_bytes + incoming_data_size) / + : (double)(_disk_capacity_bytes - _available_bytes + incoming_data_size) / (double)_disk_capacity_bytes; } @@ -146,4 +147,5 @@ class SpillStreamManager { std::atomic_uint64_t id_ = 0; }; } // namespace vectorized -} // namespace doris \ No newline at end of file +} // namespace doris +#include "common/compile_check_end.h" diff --git a/be/src/vec/spill/spill_writer.cpp b/be/src/vec/spill/spill_writer.cpp index 46a97285802ea2..bf755e76452f5d 100644 --- a/be/src/vec/spill/spill_writer.cpp +++ b/be/src/vec/spill/spill_writer.cpp @@ -27,6 +27,7 @@ #include "vec/spill/spill_stream_manager.h" namespace doris::vectorized { +#include "common/compile_check_begin.h" Status SpillWriter::open() { if (file_writer_) { return Status::OK(); diff --git a/be/src/vec/spill/spill_writer.h b/be/src/vec/spill/spill_writer.h index d77bbd6908c4ab..921bd8ea874c7f 100644 --- a/be/src/vec/spill/spill_writer.h +++ b/be/src/vec/spill/spill_writer.h @@ -25,6 +25,7 @@ #include "util/runtime_profile.h" #include "vec/core/block.h" namespace doris { +#include "common/compile_check_begin.h" class RuntimeState; namespace vectorized { @@ -86,3 +87,5 @@ class SpillWriter { using SpillWriterUPtr = std::unique_ptr; } // namespace vectorized } // namespace doris + +#include "common/compile_check_end.h"