Skip to content

Commit 2d4b8c8

Browse files
committed
[opt](profile) use same metric name as OLAP SCAN NODE for FILE SCAN NODE (#59159)
### What problem does this PR solve? Before: `FILE_SCAN_OPERATOR (id=4. nereids_id=1053. table name = warehouse):` After: `FILE_SCAN_OPERATOR (nereids_id=1052. table_name=inventory)(id=6):` Same format as OLAP_SCAN_OPERATOR
1 parent d9a931a commit 2d4b8c8

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

be/src/pipeline/exec/file_scan_operator.cpp

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -98,9 +98,10 @@ Status FileScanLocalState::_init_scanners(std::list<vectorized::ScannerSPtr>* sc
9898
}
9999

100100
std::string FileScanLocalState::name_suffix() const {
101-
return fmt::format(" (id={}. nereids_id={}. table name = {})",
102-
std::to_string(_parent->node_id()), std::to_string(_parent->nereids_id()),
103-
_parent->cast<FileScanOperatorX>()._table_name);
101+
return fmt::format("(nereids_id={}. table_name={})" + operator_name_suffix,
102+
std::to_string(_parent->nereids_id()),
103+
_parent->cast<FileScanOperatorX>()._table_name,
104+
std::to_string(_parent->node_id()));
104105
}
105106

106107
void FileScanLocalState::set_scan_ranges(RuntimeState* state,

be/src/pipeline/exec/jdbc_scan_operator.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
namespace doris::pipeline {
2424
#include "common/compile_check_begin.h"
2525
std::string JDBCScanLocalState::name_suffix() const {
26-
return fmt::format("(nereids_id={} . table name = {})" + operator_name_suffix,
26+
return fmt::format("(nereids_id={}. table_name={})" + operator_name_suffix,
2727
std::to_string(_parent->nereids_id()),
2828
_parent->cast<JDBCScanOperatorX>()._table_name,
2929
std::to_string(_parent->node_id()));

0 commit comments

Comments
 (0)