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 04fc0d41a98 [opt](regression-test) Adjust the stream load timeout 
check of the regression framework (#47037)
04fc0d41a98 is described below

commit 04fc0d41a98d4d294a499e004f0d9801cdc81902
Author: Xin Liao <liao...@selectdb.com>
AuthorDate: Thu Jan 16 10:35:55 2025 +0800

    [opt](regression-test) Adjust the stream load timeout check of the 
regression framework (#47037)
    
    stream load may cost more time than expected in regression test, because
    of case run in parallel. So we allow stream load cost more time, use 3 *
    time as threshold.
---
 .../org/apache/doris/regression/action/StreamLoadAction.groovy | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy
 
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy
index 97b6d038fa7..b0a811a2e2f 100644
--- 
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy
+++ 
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy
@@ -367,10 +367,12 @@ class StreamLoadAction implements SuiteAction {
 
             if (time > 0) {
                 long elapsed = endTime - startTime
-                if (elapsed > time) {
-                    log.info("Stream load consums more time than expected, 
elapsed ${elapsed} ms, expect ${time} ms")
-                } else {
-                    log.info("Stream load consums time elapsed ${elapsed} ms, 
expect ${time} ms")
+                try {
+                    // stream load may cost more time than expected in 
regression test, because of case run in parallel.
+                    // So we allow stream load cost more time, use 3 * time as 
threshold.
+                    Assert.assertTrue("Stream load Expect elapsed <= 3 * 
${time}, but meet ${elapsed}", elapsed <= 3 * time)
+                } catch (Throwable t) {
+                    throw new IllegalStateException("Stream load Expect 
elapsed <= 3 * ${time}, but meet ${elapsed}")
                 }
             }
         }


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

Reply via email to