[UT] Fix flaky test (#46246)

Signed-off-by: Alex Zhu <zhuming9011@gmail.com>
StarRocks · May 24, 2024 · 0951feb · 0951feb
1 parent 06f6cea
commit 0951feb
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 8 deletions.
diff --git a/be/src/runtime/lake_tablets_channel.cpp b/be/src/runtime/lake_tablets_channel.cpp
@@ -275,6 +275,7 @@ LakeTabletsChannel::~LakeTabletsChannel() {
 
 Status LakeTabletsChannel::open(const PTabletWriterOpenRequest& params, PTabletWriterOpenResult* result,
                                 std::shared_ptr<OlapTableSchemaParam> schema, bool is_incremental) {
+    DCHECK_EQ(-1, _txn_id);
     SCOPED_TIMER(_open_timer);
     COUNTER_UPDATE(_open_counter, 1);
     std::unique_lock<bthreads::BThreadSharedMutex> l(_rw_mtx);

diff --git a/be/test/runtime/lake_tablets_channel_test.cpp b/be/test/runtime/lake_tablets_channel_test.cpp
@@ -834,17 +834,17 @@ TEST_P(LakeTabletsChannelMultiSenderTest, test_dont_write_txn_log) {
         SyncPoint::GetInstance()->DisableProcessing();
     });
 
-    auto sender_task = [&](int sender_id) {
-        auto open_request = _open_request;
-        open_request.set_sender_id(sender_id);
-        open_request.set_num_senders(num_sender);
-        open_request.mutable_lake_tablet_params()->set_write_txn_log(false);
+    auto open_request = _open_request;
+    open_request.set_sender_id(0);
+    open_request.set_num_senders(num_sender);
+    open_request.mutable_lake_tablet_params()->set_write_txn_log(false);
 
-        auto open_response = PTabletWriterOpenResult{};
+    auto open_response = PTabletWriterOpenResult{};
 
-        ASSERT_OK(_tablets_channel->open(open_request, &open_response, _schema_param, false));
-        ASSERT_EQ(0, open_response.status().status_code());
+    ASSERT_OK(_tablets_channel->open(open_request, &open_response, _schema_param, false));
+    ASSERT_EQ(0, open_response.status().status_code());
 
+    auto sender_task = [&](int sender_id) {
         PTabletWriterAddChunkRequest add_chunk_request;
         PTabletWriterAddBatchResult add_chunk_response;
         add_chunk_request.set_index_id(kIndexId);