[enhancement] Cleanup some unused include

be/src/runtime/buffered_block_mgr2.cc

@@ -19,15 +19,13 @@
 
 #include "exec/exec_node.h"
 #include "runtime/exec_env.h"
-#include "runtime/mem_pool.h"
 #include "runtime/mem_tracker.h"
 #include "runtime/runtime_state.h"
 #include "runtime/tmp_file_mgr.h"
 #include "util/bit_util.h"
 #include "util/debug_util.h"
 #include "util/disk_info.h"
 #include "util/doris_metrics.h"
-#include "util/filesystem_util.h"
 #include "util/pretty_printer.h"
 #include "util/runtime_profile.h"
 #include "util/stack_util.h"

be/src/runtime/buffered_tuple_stream3.cc

@@ -26,8 +26,6 @@
 #include "runtime/tuple_row.h"
 #include "util/bit_util.h"
 #include "util/debug_util.h"
-#include "util/pretty_printer.h"
-#include "util/runtime_profile.h"
 
 #ifdef NDEBUG
 #define CHECK_CONSISTENCY_FAST()

be/src/runtime/client_cache.cpp

@@ -18,19 +18,14 @@
 #include "runtime/client_cache.h"
 
 #include <thrift/protocol/TBinaryProtocol.h>
-#include <thrift/server/TServer.h>
-#include <thrift/transport/TSocket.h>
-#include <thrift/transport/TTransportUtils.h>
 
 #include <memory>
 #include <sstream>
 
 #include "common/logging.h"
 #include "gen_cpp/FrontendService.h"
-#include "util/container_util.hpp"
 #include "util/doris_metrics.h"
 #include "util/network_util.h"
-#include "util/thrift_util.h"
 
 namespace doris {
 

be/src/runtime/collection_value.cpp

@@ -21,8 +21,6 @@
 
 #include "common/logging.h"
 #include "common/utils.h"
-#include "exprs/anyval_util.h"
-#include "exprs/literal.h"
 #include "runtime/descriptors.h"
 #include "util//mem_util.hpp"
 

be/src/runtime/data_stream_mgr.cpp

@@ -28,7 +28,6 @@
 #include "runtime/row_batch.h"
 #include "runtime/runtime_state.h"
 #include "util/doris_metrics.h"
-#include "util/uid_util.h"
 
 namespace doris {
 

be/src/runtime/data_stream_recvr.cc

@@ -32,7 +32,6 @@
 #include "util/debug_util.h"
 #include "util/logging.h"
 #include "util/runtime_profile.h"
-#include "util/uid_util.h"
 
 using std::list;
 using std::vector;

be/src/runtime/data_stream_sender.cpp

@@ -18,12 +18,10 @@
 #include "runtime/data_stream_sender.h"
 
 #include <arpa/inet.h>
-#include <thrift/protocol/TDebugProtocol.h>
 
 #include <algorithm>
 #include <iostream>
 #include <random>
-#include <thread>
 
 #include "common/config.h"
 #include "common/logging.h"

be/src/runtime/descriptors.cpp

@@ -25,7 +25,6 @@
 #include "gen_cpp/Descriptors_types.h"
 #include "gen_cpp/descriptors.pb.h"
 #include "vec/columns/column_nullable.h"
-#include "vec/core/columns_with_type_and_name.h"
 #include "vec/data_types/data_type_factory.hpp"
 #include "vec/data_types/data_type_nullable.h"
 

be/src/runtime/disk_io_mgr_scan_range.cc

@@ -18,7 +18,6 @@
 #include "runtime/disk_io_mgr.h"
 #include "runtime/disk_io_mgr_internal.h"
 #include "util/error_util.h"
-// #include "util/hdfs-util.h"
 
 using std::string;
 using std::stringstream;

be/src/runtime/dpp_writer.cpp

@@ -21,7 +21,6 @@
 
 #include <vector>
 
-#include "exprs/expr.h"
 #include "exprs/expr_context.h"
 #include "olap/utils.h"
 #include "runtime/primitive_type.h"

be/src/runtime/exec_env_init.cpp

@@ -15,13 +15,10 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include <boost/algorithm/string.hpp>
-
 #include "agent/cgroups_mgr.h"
 #include "common/config.h"
 #include "common/logging.h"
 #include "gen_cpp/BackendService.h"
-#include "gen_cpp/FrontendService.h"
 #include "gen_cpp/HeartbeatService_types.h"
 #include "gen_cpp/TExtDataSourceService.h"
 #include "gen_cpp/TPaloBrokerService.h"
@@ -55,11 +52,9 @@
 #include "runtime/tmp_file_mgr.h"
 #include "util/bfd_parser.h"
 #include "util/brpc_client_cache.h"
-#include "util/debug_util.h"
 #include "util/doris_metrics.h"
 #include "util/mem_info.h"
 #include "util/metrics.h"
-#include "util/network_util.h"
 #include "util/parse_util.h"
 #include "util/pretty_printer.h"
 #include "util/priority_thread_pool.hpp"

be/src/runtime/export_sink.cpp

@@ -28,7 +28,6 @@
 #include "exprs/expr.h"
 #include "exprs/expr_context.h"
 #include "gutil/strings/numbers.h"
-#include "runtime/mysql_table_sink.h"
 #include "runtime/row_batch.h"
 #include "runtime/runtime_state.h"
 #include "runtime/tuple_row.h"

be/src/runtime/file_result_writer.cpp

@@ -19,11 +19,9 @@
 
 #include "exec/broker_writer.h"
 #include "exec/hdfs_reader_writer.h"
-#include "exec/hdfs_writer.h"
 #include "exec/local_file_writer.h"
 #include "exec/parquet_writer.h"
 #include "exec/s3_writer.h"
-#include "exprs/expr.h"
 #include "exprs/expr_context.h"
 #include "gen_cpp/PaloInternalService_types.h"
 #include "runtime/buffer_control_block.h"

be/src/runtime/fold_constant_executor.cpp

@@ -14,10 +14,10 @@
 // KIND, either express or implied.  See the License for the
 // specific language governing permissions and limitations
 // under the License.
+
 #include "runtime/fold_constant_executor.h"
 
 #include <map>
-#include <string>
 
 #include "runtime/tuple_row.h"
 #include "runtime/exec_env.h"

be/src/runtime/initial_reservations.cc

@@ -17,8 +17,6 @@
 
 #include "runtime/initial_reservations.h"
 
-#include <gflags/gflags.h>
-
 #include <limits>
 #include <mutex>
 

be/src/runtime/memory/chunk_allocator.cpp

@@ -17,11 +17,9 @@
 
 #include "runtime/memory/chunk_allocator.h"
 
-#include <atomic>
 #include <list>
 #include <mutex>
 
-#include "gutil/dynamic_annotations.h"
 #include "runtime/mem_tracker.h"
 #include "runtime/memory/chunk.h"
 #include "runtime/memory/system_allocator.h"

be/src/runtime/memory_scratch_sink.cpp

@@ -22,19 +22,14 @@
 
 #include <sstream>
 
-#include "common/logging.h"
 #include "exprs/expr.h"
-#include "gen_cpp/DorisExternalService_types.h"
 #include "gen_cpp/Types_types.h"
 #include "runtime/exec_env.h"
 #include "runtime/primitive_type.h"
-#include "runtime/result_queue_mgr.h"
 #include "runtime/row_batch.h"
 #include "runtime/runtime_state.h"
 #include "runtime/tuple_row.h"
 #include "util/arrow/row_batch.h"
-#include "util/date_func.h"
-#include "util/types.h"
 
 namespace doris {
 

be/src/runtime/message_body_sink.cpp

@@ -18,8 +18,6 @@
 #include "runtime/message_body_sink.h"
 
 #include <fcntl.h>
-#include <sys/stat.h>
-#include <sys/types.h>
 
 #include <algorithm>
 

be/src/runtime/mysql_result_writer.cpp

@@ -17,23 +17,17 @@
 
 #include "runtime/mysql_result_writer.h"
 
-#include "exprs/expr.h"
 #include "exprs/expr_context.h"
 #include "gen_cpp/PaloInternalService_types.h"
 #include "runtime/buffer_control_block.h"
 #include "runtime/primitive_type.h"
 #include "runtime/result_buffer_mgr.h"
 #include "runtime/row_batch.h"
 #include "runtime/tuple_row.h"
-#include "util/date_func.h"
 #include "util/mysql_row_buffer.h"
 #include "util/types.h"
-#include "vec/columns/column_nullable.h"
 #include "vec/columns/column_vector.h"
-#include "vec/common/assert_cast.h"
 #include "vec/core/block.h"
-#include "vec/exprs/vexpr.h"
-#include "vec/exprs/vexpr_context.h"
 
 namespace doris {
 

be/src/runtime/mysql_table_sink.cpp

@@ -21,7 +21,6 @@
 
 #include "exprs/expr.h"
 #include "runtime/mem_tracker.h"
-#include "runtime/mysql_table_sink.h"
 #include "runtime/runtime_state.h"
 #include "util/debug_util.h"
 #include "util/runtime_profile.h"

be/src/runtime/mysql_table_writer.cpp

@@ -21,7 +21,6 @@
 
 #include <sstream>
 
-#include "exprs/expr.h"
 #include "exprs/expr_context.h"
 #include "runtime/row_batch.h"
 #include "runtime/tuple_row.h"

be/src/runtime/plan_fragment_executor.cpp

@@ -21,7 +21,6 @@
 
 #include <unordered_map>
 
-#include "common/object_pool.h"
 #include "exec/data_sink.h"
 #include "exec/exchange_node.h"
 #include "exec/exec_node.h"
@@ -36,7 +35,6 @@
 #include "runtime/row_batch.h"
 #include "runtime/thread_context.h"
 #include "util/container_util.hpp"
-#include "util/cpu_info.h"
 #include "util/logging.h"
 #include "util/mem_info.h"
 #include "util/parse_util.h"

be/src/runtime/result_buffer_mgr.cpp

@@ -21,7 +21,6 @@
 #include "gen_cpp/types.pb.h"
 #include "runtime/buffer_control_block.h"
 #include "runtime/raw_value.h"
-#include "util/debug_util.h"
 #include "util/doris_metrics.h"
 
 namespace doris {

be/src/runtime/result_file_sink.cpp

@@ -22,7 +22,6 @@
 #include "runtime/buffer_control_block.h"
 #include "runtime/exec_env.h"
 #include "runtime/file_result_writer.h"
-#include "runtime/mysql_result_writer.h"
 #include "runtime/result_buffer_mgr.h"
 #include "runtime/row_batch.h"
 #include "runtime/runtime_state.h"

be/src/runtime/result_queue_mgr.cpp

@@ -18,12 +18,9 @@
 #include "runtime/result_queue_mgr.h"
 
 #include "common/config.h"
-#include "common/logging.h"
 #include "common/status.h"
-#include "gen_cpp/DorisExternalService_types.h"
 #include "gen_cpp/Types_types.h"
 #include "runtime/exec_env.h"
-#include "util/arrow/row_batch.h"
 #include "util/doris_metrics.h"
 
 namespace doris {

be/src/runtime/routine_load/routine_load_task_executor.cpp

@@ -27,7 +27,6 @@
 #include "runtime/routine_load/data_consumer_group.h"
 #include "runtime/routine_load/kafka_consumer_pipe.h"
 #include "runtime/stream_load/stream_load_context.h"
-#include "runtime/stream_load/stream_load_executor.h"
 #include "util/defer_op.h"
 #include "util/uid_util.h"
 

be/src/runtime/runtime_filter_mgr.cpp

@@ -25,12 +25,10 @@
 #include "runtime/exec_env.h"
 #include "runtime/mem_tracker.h"
 #include "runtime/plan_fragment_executor.h"
-#include "runtime/runtime_filter_mgr.h"
 #include "runtime/runtime_state.h"
 #include "runtime/thread_context.h"
 #include "service/brpc.h"
 #include "util/brpc_client_cache.h"
-#include "util/time.h"
 
 namespace doris {
 

be/src/runtime/runtime_state.cpp

@@ -19,30 +19,24 @@
 
 #include <boost/algorithm/string/join.hpp>
 #include <fmt/format.h>
-#include <iostream>
 #include <sstream>
 #include <string>
 
 #include "common/logging.h"
 #include "common/object_pool.h"
 #include "common/status.h"
 #include "exec/exec_node.h"
-#include "exprs/expr.h"
 #include "runtime/buffered_block_mgr2.h"
 #include "runtime/bufferpool/reservation_tracker.h"
 #include "runtime/bufferpool/reservation_util.h"
-#include "runtime/descriptors.h"
 #include "runtime/exec_env.h"
 #include "runtime/initial_reservations.h"
 #include "runtime/load_path_mgr.h"
 #include "runtime/mem_tracker.h"
 #include "runtime/mem_tracker_task_pool.h"
 #include "runtime/runtime_filter_mgr.h"
-#include "util/cpu_info.h"
-#include "util/disk_info.h"
 #include "util/file_utils.h"
 #include "util/load_error_hub.h"
-#include "util/mem_info.h"
 #include "util/pretty_printer.h"
 #include "util/timezone_utils.h"
 #include "util/uid_util.h"

be/src/runtime/small_file_mgr.cpp

@@ -20,7 +20,6 @@
 #include <stdint.h>
 #include <stdio.h>
 
-#include <boost/algorithm/string/classification.hpp> // boost::is_any_of
 #include <boost/algorithm/string/predicate.hpp>      // boost::algorithm::starts_with
 #include <sstream>
 

be/src/runtime/snapshot_loader.cpp

@@ -21,8 +21,6 @@
 
 #include "common/logging.h"
 #include "env/env.h"
-#include "exec/broker_reader.h"
-#include "exec/broker_writer.h"
 #include "gen_cpp/FrontendService.h"
 #include "gen_cpp/FrontendService_types.h"
 #include "gen_cpp/HeartbeatService_types.h"

be/src/runtime/stream_load/stream_load_executor.cpp

@@ -23,7 +23,6 @@
 #include "runtime/exec_env.h"
 #include "runtime/fragment_mgr.h"
 #include "runtime/plan_fragment_executor.h"
-#include "runtime/runtime_state.h"
 #include "runtime/stream_load/stream_load_context.h"
 #include "util/doris_metrics.h"
 #include "util/thrift_rpc_helper.h"

be/src/runtime/thread_resource_mgr.cpp

@@ -17,7 +17,6 @@
 
 #include "runtime/thread_resource_mgr.h"
 
-#include <boost/algorithm/string.hpp>
 #include <vector>
 
 #include "common/config.h"

be/src/runtime/threadlocal.cc

@@ -20,7 +20,6 @@
 
 #include <memory>
 #include <ostream>
-#include <string>
 
 #include "common/logging.h"
 #include "gutil/once.h"