diff --git a/dbms/src/DataStreams/HashJoinBuildBlockInputStream.h b/dbms/src/DataStreams/HashJoinBuildBlockInputStream.h index dbfc7f30310..5b99c17ec59 100644 --- a/dbms/src/DataStreams/HashJoinBuildBlockInputStream.h +++ b/dbms/src/DataStreams/HashJoinBuildBlockInputStream.h @@ -22,7 +22,7 @@ namespace DB { class HashJoinBuildBlockInputStream : public IProfilingBlockInputStream { - static constexpr auto NAME = "HashJoinBuildBlockInputStream"; + static constexpr auto NAME = "HashJoinBuild"; public: HashJoinBuildBlockInputStream( diff --git a/dbms/src/DataStreams/TiRemoteBlockInputStream.h b/dbms/src/DataStreams/TiRemoteBlockInputStream.h index 990630507da..dfc44088acb 100644 --- a/dbms/src/DataStreams/TiRemoteBlockInputStream.h +++ b/dbms/src/DataStreams/TiRemoteBlockInputStream.h @@ -177,7 +177,7 @@ class TiRemoteBlockInputStream : public IProfilingBlockInputStream TiRemoteBlockInputStream(std::shared_ptr remote_reader_, const String & req_id, const String & executor_id, size_t stream_id_) : remote_reader(remote_reader_) , source_num(remote_reader->getSourceNum()) - , name(fmt::format("TiRemoteBlockInputStream({})", RemoteReader::name)) + , name(fmt::format("TiRemote({})", RemoteReader::name)) , execution_summaries_inited(source_num) , log(Logger::get(name, req_id, executor_id)) , total_rows(0) diff --git a/dbms/src/Flash/Planner/tests/gtest_physical_plan.cpp b/dbms/src/Flash/Planner/tests/gtest_physical_plan.cpp index c26e4c9f298..b02289fbdf9 100644 --- a/dbms/src/Flash/Planner/tests/gtest_physical_plan.cpp +++ b/dbms/src/Flash/Planner/tests/gtest_physical_plan.cpp @@ -373,7 +373,7 @@ try | is_tidb_operator: true, schema: , )", /*expected_streams=*/R"( CreatingSets - HashJoinBuildBlockInputStream: , join_kind = Inner + HashJoinBuild: , join_kind = Inner Expression: Expression: MockExchangeReceiver @@ -400,7 +400,7 @@ CreatingSets | is_tidb_operator: true, schema: , )", /*expected_streams=*/R"( CreatingSets - HashJoinBuildBlockInputStream: , join_kind = Left + HashJoinBuild: , join_kind = Left Expression: Expression: MockExchangeReceiver @@ -427,7 +427,7 @@ CreatingSets | is_tidb_operator: true, schema: , )", /*expected_streams=*/R"( CreatingSets - HashJoinBuildBlockInputStream: , join_kind = Right + HashJoinBuild: , join_kind = Right Expression: Expression: MockExchangeReceiver @@ -474,12 +474,12 @@ CreatingSets | is_tidb_operator: true, schema: , )", /*expected_streams=*/R"( CreatingSets - HashJoinBuildBlockInputStream x 2: , join_kind = Right + HashJoinBuild x 2: , join_kind = Right Expression: Expression: MockTableScan Union: - HashJoinBuildBlockInputStream: , join_kind = Inner + HashJoinBuild: , join_kind = Inner Expression: Expression: Expression: @@ -487,7 +487,7 @@ CreatingSets Expression: Expression: MockTableScan - HashJoinBuildBlockInputStream: , join_kind = Inner + HashJoinBuild: , join_kind = Inner Expression: Expression: Expression: @@ -544,12 +544,12 @@ CreatingSets | is_tidb_operator: true, schema: , )", /*expected_streams=*/R"( CreatingSets - HashJoinBuildBlockInputStream x 2: , join_kind = Right + HashJoinBuild x 2: , join_kind = Right Expression: Expression: MockTableScan Union: - HashJoinBuildBlockInputStream: , join_kind = Left + HashJoinBuild: , join_kind = Left Expression: Expression: Expression: @@ -557,7 +557,7 @@ CreatingSets Expression: Expression: MockTableScan - HashJoinBuildBlockInputStream: , join_kind = Left + HashJoinBuild: , join_kind = Left Expression: Expression: Expression: diff --git a/dbms/src/Flash/tests/gtest_interpreter.cpp b/dbms/src/Flash/tests/gtest_interpreter.cpp index ff0d2f05e34..e7be8af9995 100644 --- a/dbms/src/Flash/tests/gtest_interpreter.cpp +++ b/dbms/src/Flash/tests/gtest_interpreter.cpp @@ -416,12 +416,12 @@ try String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockTableScan Union x 2: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: Expression: @@ -458,12 +458,12 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockExchangeReceiver Union x 2: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: Expression: @@ -501,12 +501,12 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockExchangeReceiver Union x 2: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: Expression: @@ -542,7 +542,7 @@ try String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockTableScan @@ -571,7 +571,7 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Right + HashJoinBuild x 10: , join_kind = Right Expression: Expression: MockTableScan @@ -605,7 +605,7 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 20: , join_kind = Right + HashJoinBuild x 20: , join_kind = Right Expression: Expression: MockExchangeReceiver diff --git a/dbms/src/Flash/tests/gtest_planner_interpreter.cpp b/dbms/src/Flash/tests/gtest_planner_interpreter.cpp index 744126d5f7c..ce22cea1509 100644 --- a/dbms/src/Flash/tests/gtest_planner_interpreter.cpp +++ b/dbms/src/Flash/tests/gtest_planner_interpreter.cpp @@ -446,7 +446,7 @@ MockExchangeSender String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: SharedQuery: @@ -762,12 +762,12 @@ try String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockTableScan Union x 2: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: Expression: @@ -804,12 +804,12 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockExchangeReceiver Union x 2: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: Expression: @@ -847,12 +847,12 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockExchangeReceiver Union x 2: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: Expression: @@ -888,7 +888,7 @@ try String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Left + HashJoinBuild x 10: , join_kind = Left Expression: Expression: MockTableScan @@ -919,7 +919,7 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 10: , join_kind = Right + HashJoinBuild x 10: , join_kind = Right Expression: Expression: MockTableScan @@ -956,7 +956,7 @@ CreatingSets String expected = R"( CreatingSets Union: - HashJoinBuildBlockInputStream x 20: , join_kind = Right + HashJoinBuild x 20: , join_kind = Right Expression: Expression: MockExchangeReceiver diff --git a/dbms/src/Flash/tests/gtest_split_tasks.cpp b/dbms/src/Flash/tests/gtest_split_tasks.cpp index 1155c450594..207a852f434 100644 --- a/dbms/src/Flash/tests/gtest_split_tasks.cpp +++ b/dbms/src/Flash/tests/gtest_split_tasks.cpp @@ -117,7 +117,7 @@ try " Expression: \n" " MockTableScan", "CreatingSets\n" - " HashJoinBuildBlockInputStream: , join_kind = Left\n" + " HashJoinBuild: , join_kind = Left\n" " Expression: \n" " Expression: \n" " MockExchangeReceiver\n"