database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](test) fix move memtable injection test may cause other case stuck #40356 (#42508)

Browse Source 
cherry pick from #40356

---------

Co-authored-by: hui lai <1353307710@qq.com>
This commit is contained in:
Xin Liao
2024-10-26 23:11:45 +08:00
committed by GitHub
parent 1c9a798b68
commit 2bb29d7f36
3 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/olap/delta_writer_v2.cpp
View File

@ -153,7 +153,7 @@ Status DeltaWriterV2::write(const vectorized::Block* block, const std::vector<ui
SCOPED_RAW_TIMER(&_wait_flush_limit_time);
auto memtable_flush_running_count_limit = config::memtable_flush_running_count_limit;
DBUG_EXECUTE_IF("DeltaWriterV2.write.back_pressure",
{ memtable_flush_running_count_limit = 0; });
{ std::this_thread::sleep_for(std::chrono::milliseconds(10 * 1000)); });
while (_memtable_writer->flush_running_count() >= memtable_flush_running_count_limit) {
if (_state->is_cancelled()) {
return Status::Cancelled(_state->cancel_reason());

1
regression-test/pipeline/p0/conf/regression-conf.groovy
View File

@ -70,7 +70,6 @@ excludeSuites = "000_the_start_sentinel_do_not_touch," + // keep this line as th
"test_spark_load," +
"test_broker_load_func," +
"test_stream_stub_fault_injection," +
"test_delta_writer_v2_back_pressure_fault_injection," +
"zzz_the_end_sentinel_do_not_touch" // keep this line as the last line
// this directories will not be executed

4
regression-test/suites/fault_injection_p0/test_delta_writer_v2_back_pressure_fault_injection.groovy
View File

@ -98,9 +98,11 @@ suite("test_delta_writer_v2_back_pressure_fault_injection", "nonConcurrent") {
}
} catch(Exception e) {
logger.info(e.getMessage())
} finally {
GetDebugPoint().disableDebugPointForAllBEs("DeltaWriterV2.write.back_pressure")
}
sql """ DROP TABLE IF EXISTS `baseall` """
sql """ DROP TABLE IF EXISTS `test` """
sql """ set enable_memtable_on_sink_node=false """
}
}