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

dataroaring 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 1faa684d206 [debug](do not merge) add routine load debug info (#48592)
1faa684d206 is described below

commit 1faa684d2063a0459f7a070aee837ca75cfe7388
Author: hui lai <lai...@selectdb.com>
AuthorDate: Tue Mar 4 16:31:38 2025 +0800

    [debug](do not merge) add routine load debug info (#48592)
---
 .../suites/load_p0/routine_load/test_routine_load_condition.groovy    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/regression-test/suites/load_p0/routine_load/test_routine_load_condition.groovy
 
b/regression-test/suites/load_p0/routine_load/test_routine_load_condition.groovy
index 7735867c749..3676679a894 100644
--- 
a/regression-test/suites/load_p0/routine_load/test_routine_load_condition.groovy
+++ 
b/regression-test/suites/load_p0/routine_load/test_routine_load_condition.groovy
@@ -156,6 +156,8 @@ suite("test_routine_load_condition","p0") {
                     continue;
                 }
                 log.info("reason of state changed: 
${res[0][11].toString()}".toString())
+                log.info("routine load progress: 
${res[0][15].toString()}".toString())
+                log.info("routine load lag: 
${res[0][16].toString()}".toString())
                 def json = parseJson(res[0][11])
                 assertEquals("(`k12` >= date_sub(curdate(), INTERVAL 2 DAY))", 
json.whereExpr.toString())
                 break;
@@ -164,6 +166,8 @@ suite("test_routine_load_condition","p0") {
                 sleep(1000)
                 def res = sql "show routine load for ${jobName}"
                 log.info("routine load statistic: 
${res[0][14].toString()}".toString())
+                log.info("routine load progress: 
${res[0][15].toString()}".toString())
+                log.info("routine load lag: 
${res[0][16].toString()}".toString())
                 def json = parseJson(res[0][14])
                 if (json.unselectedRows.toString() != "20") {
                     count++


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

Reply via email to