Skip to content

Commit 241a956

Browse files
[refactor](remove unused code) remove partition info from datastream sender (#16162)
--------- Co-authored-by: yiguolei <yiguolei@gmail.com>
1 parent 26fc7c8 commit 241a956

15 files changed

Lines changed: 2 additions & 1104 deletions

be/src/pipeline/exec/exchange_sink_operator.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
#include "gen_cpp/internal_service.pb.h"
2323
#include "util/brpc_client_cache.h"
2424
#include "vec/exprs/vexpr.h"
25-
#include "vec/runtime/vpartition_info.h"
2625
#include "vec/sink/vdata_stream_sender.h"
2726

2827
namespace doris::pipeline {

be/src/runtime/CMakeLists.txt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@ set(RUNTIME_FILES
3535
mem_pool.cpp
3636
plan_fragment_executor.cpp
3737
primitive_type.cpp
38-
raw_value.cpp
3938
result_buffer_mgr.cpp
4039
result_writer.cpp
4140
runtime_state.cpp
@@ -50,7 +49,6 @@ set(RUNTIME_FILES
5049
collection_value.cpp
5150
tuple.cpp
5251
fragment_mgr.cpp
53-
dpp_sink_internal.cpp
5452
load_path_mgr.cpp
5553
types.cpp
5654
tmp_file_mgr.cc

be/src/runtime/dpp_sink_internal.cpp

Lines changed: 0 additions & 137 deletions
This file was deleted.

be/src/runtime/dpp_sink_internal.h

Lines changed: 0 additions & 186 deletions
This file was deleted.

0 commit comments

Comments
 (0)