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 a15465d6f39 [test](injection) clean leaked load streams by idle 
timeout (#39859)
a15465d6f39 is described below

commit a15465d6f39f2f7b41b871d9147b9575a9de3abb
Author: Kaijie Chen <c...@apache.org>
AuthorDate: Fri Aug 23 23:33:05 2024 +0800

    [test](injection) clean leaked load streams by idle timeout (#39859)
    
    Open stream failure fault injection caused load stream leak because
    `use_cnt` cannot drop to `0`.
    This PR reduce the idle timeout for this injection case, which equals to
    load timeout.
    On idle timeout, load streams are supposed to be closed.
---
 .../fault_injection_p0/test_multi_replica_fault_injection.groovy   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/regression-test/suites/fault_injection_p0/test_multi_replica_fault_injection.groovy
 
b/regression-test/suites/fault_injection_p0/test_multi_replica_fault_injection.groovy
index 33f7e28dbc9..bd1cebdcc10 100644
--- 
a/regression-test/suites/fault_injection_p0/test_multi_replica_fault_injection.groovy
+++ 
b/regression-test/suites/fault_injection_p0/test_multi_replica_fault_injection.groovy
@@ -98,7 +98,12 @@ suite("test_multi_replica_fault_injection", "nonConcurrent") 
{
         // test segment num check when LoadStreamStub missed tail segments
         load_with_injection("LoadStreamStub.only_send_segment_0", "segment num 
mismatch")
         // test 1st stream to each backend failure
-        
load_with_injection("VTabletWriterV2._open_streams_to_backend.one_stream_open_failure",
 "success")
+        try {
+            sql "set insert_timeout=120"
+            
load_with_injection("VTabletWriterV2._open_streams_to_backend.one_stream_open_failure",
 "success")
+        } finally {
+            sql "set insert_timeout=14400"
+        }
         // test one backend open failure
         load_with_injection("VTabletWriterV2._open_streams.skip_one_backend", 
"success")
         sql """ set enable_memtable_on_sink_node=false """


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to