This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new ddaec4733e0 [fix](test) fix move memtable injection test may cause
other case stuck (#40356)
ddaec4733e0 is described below
commit ddaec4733e0f40fe84a1965cd800015c1a221723
Author: hui lai <[email protected]>
AuthorDate: Thu Sep 5 18:51:39 2024 +0800
[fix](test) fix move memtable injection test may cause other case stuck
(#40356)
Fix move memtable injection test may cause other case stuck.
---
be/src/olap/delta_writer_v2.cpp | 2 +-
regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy | 1 -
regression-test/pipeline/p0/conf/regression-conf.groovy | 1 -
3 files changed, 1 insertion(+), 3 deletions(-)
diff --git a/be/src/olap/delta_writer_v2.cpp b/be/src/olap/delta_writer_v2.cpp
index 4b9f4231bf1..2bd1fa6a111 100644
--- a/be/src/olap/delta_writer_v2.cpp
+++ b/be/src/olap/delta_writer_v2.cpp
@@ -154,7 +154,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 _state->cancel_reason();
diff --git
a/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy
b/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy
index 10b97133a31..8d6b265a54b 100644
--- a/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy
+++ b/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy
@@ -45,7 +45,6 @@ excludeSuites = "000_the_start_sentinel_do_not_touch," + //
keep this line as th
"test_query_sys_rowsets," + // rowsets sys table
"test_unique_table_debug_data," + // disable auto compaction
"test_insert," + // txn insert
- "test_delta_writer_v2_back_pressure_fault_injection," +
"test_full_compaction_run_status," +
"test_topn_fault_injection," +
"zzz_the_end_sentinel_do_not_touch" // keep this line as the last line
diff --git a/regression-test/pipeline/p0/conf/regression-conf.groovy
b/regression-test/pipeline/p0/conf/regression-conf.groovy
index f90c3fb1df3..0b8c3a25089 100644
--- a/regression-test/pipeline/p0/conf/regression-conf.groovy
+++ b/regression-test/pipeline/p0/conf/regression-conf.groovy
@@ -71,7 +71,6 @@ excludeSuites = "000_the_start_sentinel_do_not_touch," + //
keep this line as th
"test_broker_load_func," +
"test_stream_stub_fault_injection," +
"test_index_compaction_failure_injection," +
- "test_delta_writer_v2_back_pressure_fault_injection," +
"test_full_compaction_run_status," +
"test_topn_fault_injection," +
"zzz_the_end_sentinel_do_not_touch" // keep this line as the last line
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
