(doris) 02/05: [fix](test) fix disableDebugPointForAllBEs do not execute (#30023)

[yiguolei]

This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git

commit d101234be13986984c6874a234671f778331b9db
Author: HHoflittlefish777 <77738092+hhoflittlefish...@users.noreply.github.com>
AuthorDate: Tue Jan 16 20:07:28 2024 +0800

    [fix](test) fix disableDebugPointForAllBEs do not execute (#30023)
---
 .../test_load_stream_back_pressure_fault_injection.groovy         | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/regression-test/suites/fault_injection_p0/test_load_stream_back_pressure_fault_injection.groovy
 
b/regression-test/suites/fault_injection_p0/test_load_stream_back_pressure_fault_injection.groovy
index 57825c80d17..fc2abe7fb0a 100644
--- 
a/regression-test/suites/fault_injection_p0/test_load_stream_back_pressure_fault_injection.groovy
+++ 
b/regression-test/suites/fault_injection_p0/test_load_stream_back_pressure_fault_injection.groovy
@@ -78,8 +78,6 @@ suite("test_load_stream_back_pressure_fault_injection", 
"nonConcurrent") {
             } catch(Exception e) {
                 logger.info(e.getMessage())
                 assertTrue(e.getMessage().contains("Communications link 
failure"))
-            } finally {
-                
GetDebugPoint().disableDebugPointForAllBEs("TabletStream.append_data.long_wait")
             }
         })
         thread1.start()
@@ -98,6 +96,8 @@ suite("test_load_stream_back_pressure_fault_injection", 
"nonConcurrent") {
         }
     } catch(Exception e) {
         logger.info(e.getMessage())
+    } finally {
+        
GetDebugPoint().disableDebugPointForAllBEs("TabletStream.append_data.long_wait")
     }
 
     try {
@@ -109,8 +109,6 @@ suite("test_load_stream_back_pressure_fault_injection", 
"nonConcurrent") {
             } catch(Exception e) {
                 logger.info(e.getMessage())
                 assertTrue(e.getMessage().contains("Communications link 
failure"))
-            } finally {
-                
GetDebugPoint().disableDebugPointForAllBEs("TabletStream.add_segment.long_wait")
             }
         })
         thread1.start()
@@ -129,6 +127,8 @@ suite("test_load_stream_back_pressure_fault_injection", 
"nonConcurrent") {
         }
     } catch(Exception e) {
         logger.info(e.getMessage())
+    } finally {
+        
GetDebugPoint().disableDebugPointForAllBEs("TabletStream.add_segment.long_wait")
     }
 
     sql """ DROP TABLE IF EXISTS `baseall` """


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