This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 49d17f2be2b5a36f31e353f39f93197f4b72e719 Author: Kaijie Chen <[email protected]> AuthorDate: Mon Jan 29 19:51:44 2024 +0800 [fix](move-memtable) fix potential duplicate of TabletStream profile (#30397) --- be/src/runtime/load_stream.cpp | 2 +- be/test/runtime/load_stream_test.cpp | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/be/src/runtime/load_stream.cpp b/be/src/runtime/load_stream.cpp index c62f5e9da50..430abe609bf 100644 --- a/be/src/runtime/load_stream.cpp +++ b/be/src/runtime/load_stream.cpp @@ -292,8 +292,8 @@ Status IndexStream::_init_tablet_stream(TabletStreamSharedPtr& tablet_stream, in int64_t partition_id) { tablet_stream = std::make_shared<TabletStream>(_load_id, tablet_id, _txn_id, _load_stream_mgr, _profile); - RETURN_IF_ERROR(tablet_stream->init(_schema, _id, partition_id)); _tablet_streams_map[tablet_id] = tablet_stream; + RETURN_IF_ERROR(tablet_stream->init(_schema, _id, partition_id)); return Status::OK(); } diff --git a/be/test/runtime/load_stream_test.cpp b/be/test/runtime/load_stream_test.cpp index ca065f91a68..d248e1019f4 100644 --- a/be/test/runtime/load_stream_test.cpp +++ b/be/test/runtime/load_stream_test.cpp @@ -804,7 +804,8 @@ TEST_F(LoadStreamMgrTest, one_client_abnormal_tablet) { wait_for_ack(3); EXPECT_EQ(g_response_stat.num, 3); EXPECT_EQ(g_response_stat.success_tablet_ids.size(), 0); - EXPECT_EQ(g_response_stat.failed_tablet_ids.size(), 1); + EXPECT_EQ(g_response_stat.failed_tablet_ids.size(), 2); + EXPECT_EQ(g_response_stat.failed_tablet_ids[1], ABNORMAL_TABLET_ID); // server will close stream on CLOSE_LOAD wait_for_close(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
