You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2024/01/30 07:33:59 UTC
(doris) 01/24: [fix](move-memtable) fix potential duplicate of TabletStream profile (#30397)
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 <ck...@apache.org>
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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org