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


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new 01469e11cfb [fix](regression-test) fix test_routine_load_eof case 
unstable (#46644)
01469e11cfb is described below

commit 01469e11cfb05aa962d18e372ebb2b07bc0ba796
Author: hui lai <[email protected]>
AuthorDate: Thu Jan 9 08:13:36 2025 +0800

    [fix](regression-test) fix test_routine_load_eof case unstable (#46644)
    
    ### What problem does this PR solve?
    
    Issue Number: close #xxx
    
    Related PR: #xxx
    
    Problem Summary:
    
    ### Release note
    
    None
    
    ### Check List (For Author)
    
    - Test <!-- At least one of them must be included. -->
        - [ ] Regression test
        - [ ] Unit Test
        - [ ] Manual test (add detailed scripts or steps below)
        - [ ] No need to test or manual test. Explain why:
    - [ ] This is a refactor/code format and no logic has been changed.
            - [ ] Previous test can cover this change.
            - [ ] No code files have been changed.
            - [ ] Other reason <!-- Add your reason?  -->
    
    - Behavior changed:
        - [ ] No.
        - [ ] Yes. <!-- Explain the behavior change -->
    
    - Does this need documentation?
        - [ ] No.
    - [ ] Yes. <!-- Add document PR link here. eg:
    https://github.com/apache/doris-website/pull/1214 -->
    
    ### Check List (For Reviewer who merge this PR)
    
    - [ ] Confirm the release note
    - [ ] Confirm test cases
    - [ ] Confirm document
    - [ ] Add branch pick label <!-- Add branch pick label that this PR
    should merge into -->
    
    Co-authored-by: yiguolei <[email protected]>
---
 regression-test/pipeline/p0/conf/regression-conf.groovy              | 1 -
 .../suites/load_p0/routine_load/test_routine_load_eof.groovy         | 5 +++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/regression-test/pipeline/p0/conf/regression-conf.groovy 
b/regression-test/pipeline/p0/conf/regression-conf.groovy
index 7fa505aa1c9..d6d409c3c2b 100644
--- a/regression-test/pipeline/p0/conf/regression-conf.groovy
+++ b/regression-test/pipeline/p0/conf/regression-conf.groovy
@@ -63,7 +63,6 @@ excludeGroups = ""
 
 excludeSuites = "000_the_start_sentinel_do_not_touch," + // keep this line as 
the first line
     "test_bitmap_filter," +
-    "test_routine_load_eof," +
     "test_cumu_compaction_with_delete," +
     "test_dump_image," +
     "test_index_failure_injection," +
diff --git 
a/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy 
b/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy
index 5e61a3ec1d0..d4078896068 100644
--- a/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy
+++ b/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy
@@ -40,6 +40,7 @@ suite("test_routine_load_eof","p0") {
             // Create kafka producer
             def producer = new KafkaProducer<>(props)
 
+            def count = 0
             while(true) {
                 Thread.sleep(1000)
                 for (String kafkaCsvTopic in kafkaCsvTpoics) {
@@ -51,6 +52,10 @@ suite("test_routine_load_eof","p0") {
                         producer.send(record)
                     }
                 }
+                if (count >= 120) {
+                    break
+                }
+                count++
             }
         }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to