From 01469e11cfb05aa962d18e372ebb2b07bc0ba796 Mon Sep 17 00:00:00 2001
From: hui lai <laihui@selectdb.com>
Date: Thu, 9 Jan 2025 08:13:36 +0800
Subject: [PATCH] [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 <guolei@selectdb.com>
---
 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 7fa505aa1c..d6d409c3c2 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 5e61a3ec1d..d407889606 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++
             }
         }