diff --git a/be/src/agent/task_worker_pool.cpp b/be/src/agent/task_worker_pool.cpp index bfa1b2f67b..0867cb3c25 100644 --- a/be/src/agent/task_worker_pool.cpp +++ b/be/src/agent/task_worker_pool.cpp @@ -717,8 +717,8 @@ void TaskWorkerPool::_publish_version_worker_thread_callback() { _tasks.push_back(agent_task_req); _worker_thread_condition_variable.notify_one(); } - LOG(INFO) << "wait for previous publish version task to be done" - << "transaction_id: " << publish_version_req.transaction_id; + LOG_EVERY_SECOND(INFO) << "wait for previous publish version task to be done" + << "transaction_id: " << publish_version_req.transaction_id; break; } else { LOG_WARNING("failed to publish version") diff --git a/be/src/olap/tablet.cpp b/be/src/olap/tablet.cpp index 25b1c18b1e..cfd4a0ed72 100644 --- a/be/src/olap/tablet.cpp +++ b/be/src/olap/tablet.cpp @@ -2723,13 +2723,16 @@ Status Tablet::calc_delete_bitmap(RowsetSharedPtr rowset, &loc); if (st.ok()) { delete_bitmap->add({rowset_id, loc.segment_id, 0}, loc.row_id); - ++row_id; - continue; } else if (st.is()) { delete_bitmap->add({rowset_id, seg->id(), 0}, row_id); - ++row_id; - continue; + } else if (!st.is_not_found()) { + // some unexpected error + LOG(WARNING) << "some unexpected error happen while looking up keys " + << "in pre segments: " << st; + return st; } + ++row_id; + continue; } // same row in segments should be filtered if (delete_bitmap->contains({rowset_id, seg->id(), 0}, row_id)) {