diff --git a/be/src/olap/delta_writer_v2.cpp b/be/src/olap/delta_writer_v2.cpp index 9d573ce308..32baa93be1 100644 --- a/be/src/olap/delta_writer_v2.cpp +++ b/be/src/olap/delta_writer_v2.cpp @@ -153,7 +153,7 @@ Status DeltaWriterV2::write(const vectorized::Block* block, const std::vectorflush_running_count() >= memtable_flush_running_count_limit) { if (_state->is_cancelled()) { return Status::Cancelled(_state->cancel_reason()); diff --git a/regression-test/pipeline/p0/conf/regression-conf.groovy b/regression-test/pipeline/p0/conf/regression-conf.groovy index 0412cfa748..741cec08ce 100644 --- a/regression-test/pipeline/p0/conf/regression-conf.groovy +++ b/regression-test/pipeline/p0/conf/regression-conf.groovy @@ -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 diff --git a/regression-test/suites/fault_injection_p0/test_delta_writer_v2_back_pressure_fault_injection.groovy b/regression-test/suites/fault_injection_p0/test_delta_writer_v2_back_pressure_fault_injection.groovy index ea9e9ffb8b..07cda8db41 100644 --- a/regression-test/suites/fault_injection_p0/test_delta_writer_v2_back_pressure_fault_injection.groovy +++ b/regression-test/suites/fault_injection_p0/test_delta_writer_v2_back_pressure_fault_injection.groovy @@ -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 """ -} \ No newline at end of file +}