This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch lsy_new_pipeline in repository https://gitbox.apache.org/repos/asf/doris.git
commit 480c43b69761fa2fee43542446a60ac8c2a1be14 Author: morningman <[email protected]> AuthorDate: Mon Nov 28 17:12:44 2022 +0800 add def --- regression-test/suites/load_p0/broker_load/test_broker_load.groovy | 4 ++-- .../suites/load_p0/stream_load/test_hdfs_json_load.groovy | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/regression-test/suites/load_p0/broker_load/test_broker_load.groovy b/regression-test/suites/load_p0/broker_load/test_broker_load.groovy index af900de061..6a837bb8ab 100644 --- a/regression-test/suites/load_p0/broker_load/test_broker_load.groovy +++ b/regression-test/suites/load_p0/broker_load/test_broker_load.groovy @@ -213,7 +213,7 @@ suite("test_broker_load", "p0") { sql """ADMIN SET FRONTEND CONFIG ("enable_new_load_scan_node" = "true");""" set_be_config.call('true') try { - i = 0 + def i = 0 for (String table in tables) { sql new File("""${context.file.parent}/ddl/${table}_drop.sql""").text sql new File("""${context.file.parent}/ddl/${table}_create.sql""").text @@ -227,7 +227,7 @@ suite("test_broker_load", "p0") { i = 0 for (String label in uuids) { - max_try_milli_secs = 600000 + def max_try_milli_secs = 600000 while (max_try_milli_secs > 0) { String[][] result = sql """ show load where label="$label" order by createtime desc limit 1; """ if (result[0][2].equals("FINISHED")) { diff --git a/regression-test/suites/load_p0/stream_load/test_hdfs_json_load.groovy b/regression-test/suites/load_p0/stream_load/test_hdfs_json_load.groovy index f3311037f3..be543a0ea3 100644 --- a/regression-test/suites/load_p0/stream_load/test_hdfs_json_load.groovy +++ b/regression-test/suites/load_p0/stream_load/test_hdfs_json_load.groovy @@ -82,11 +82,11 @@ suite("test_hdfs_json_load", "p0") { } def check_load_result = {checklabel, testTablex -> - max_try_milli_secs = 30000 + def max_try_milli_secs = 30000 while(max_try_milli_secs) { - result = sql "show load where label = '${checklabel}'" + def result = sql "show load where label = '${checklabel}'" if(result[0][2] == "FINISHED") { - log.info("LOAD FINISHED!") + log.info("LOAD FINISHED: ${checklabel}") break } else { sleep(1000) // wait 1 second every time --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
