[BugFix] Fix tablet not release if ingestion transaction is abort (ba…

…ckport #51932) (#51970) Co-authored-by: zhangqiang <[email protected]>
StarRocks · Oct 21, 2024 · 3b9dd61 · 3b9dd61
1 parent faff693
commit 3b9dd61
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/be/src/runtime/local_tablets_channel.cpp b/be/src/runtime/local_tablets_channel.cpp
@@ -267,7 +267,8 @@ void LocalTabletsChannel::add_chunk(Chunk* chunk, const PTabletWriterAddChunkReq
  auto& delta_writer = it->second;
 
  // back pressure OlapTableSink since there are too many memtables need to flush
- while (delta_writer->get_flush_stats().queueing_memtable_num >= config::max_queueing_memtable_per_tablet) {
+ while (delta_writer->get_state() != kAborted &&
+ delta_writer->get_flush_stats().queueing_memtable_num >= config::max_queueing_memtable_per_tablet) {
  if (watch.elapsed_time() / 1000000 > request.timeout_ms()) {
  LOG(INFO) << "LocalTabletsChannel txn_id: " << _txn_id << " load_id: " << print_id(request.id())
  << " wait tablet " << tablet_id << " flush memtable " << request.timeout_ms()