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++
             }
         }