This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 99edbaf3cf1 [improve](move-memtable) add stream sink file writer
finalize fault injection (#29552)
99edbaf3cf1 is described below
commit 99edbaf3cf1dc8849de5cb647e4aed460b399e54
Author: HHoflittlefish777 <[email protected]>
AuthorDate: Thu Jan 4 23:02:58 2024 +0800
[improve](move-memtable) add stream sink file writer finalize fault
injection (#29552)
---
be/src/io/fs/stream_sink_file_writer.cpp | 1 +
.../fault_injection_p0/test_load_stream_stub_failure_injection.groovy | 2 ++
2 files changed, 3 insertions(+)
diff --git a/be/src/io/fs/stream_sink_file_writer.cpp
b/be/src/io/fs/stream_sink_file_writer.cpp
index 8a14f667d1f..cfc924fad0a 100644
--- a/be/src/io/fs/stream_sink_file_writer.cpp
+++ b/be/src/io/fs/stream_sink_file_writer.cpp
@@ -128,6 +128,7 @@ Status StreamSinkFileWriter::finalize() {
<< ", reason: " << st;
}
}
+ DBUG_EXECUTE_IF("StreamSinkFileWriter.finalize.finalize_failed", { ok =
false; });
if (!ok) {
std::stringstream ss;
for (auto& stream : _streams) {
diff --git
a/regression-test/suites/fault_injection_p0/test_load_stream_stub_failure_injection.groovy
b/regression-test/suites/fault_injection_p0/test_load_stream_stub_failure_injection.groovy
index 7ad2b1e71eb..0f75cb12a62 100644
---
a/regression-test/suites/fault_injection_p0/test_load_stream_stub_failure_injection.groovy
+++
b/regression-test/suites/fault_injection_p0/test_load_stream_stub_failure_injection.groovy
@@ -83,6 +83,8 @@ suite("test_stream_stub_fault_injection", "nonConcurrent") {
// StreamSinkFileWriter appendv write segment failed all replica
load_with_injection("StreamSinkFileWriter.appendv.write_segment_failed_all_replica",
"failed to write any replicas")
+ // StreamSinkFileWriter finalize failed
+ load_with_injection("StreamSinkFileWriter.finalize.finalize_failed",
"failed to finalize any replicas")
// LoadStreams stream wait failed
load_with_injection("LoadStreamStub._send_with_retry.stream_write_failed",
"StreamWrite failed, err=32")
// LoadStreams keeping stream when release
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
