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
commit 0d0a96d097cbd0697d18895231b653de5244a2bd
Author: zfr95 <87513668+zfr9...@users.noreply.github.com>
AuthorDate: Mon Apr 8 10:56:59 2024 +0800
[fix](test) Fix auto partition dbgen product data (#33313)
Fix auto partition dbgen product data
---
.../partition_p1/auto_partition/sql/multi_thread_load.groovy | 12 ++++++++++++
.../auto_partition/sql/stress_test_insert_into.groovy | 1 +
.../diff_data/stress_test_diff_date_list.groovy | 1 -
3 files changed, 13 insertions(+), 1 deletion(-)
diff --git
a/regression-test/suites/partition_p1/auto_partition/sql/multi_thread_load.groovy
b/regression-test/suites/partition_p1/auto_partition/sql/multi_thread_load.groovy
index f515c25b0be..4361fb96771 100644
---
a/regression-test/suites/partition_p1/auto_partition/sql/multi_thread_load.groovy
+++
b/regression-test/suites/partition_p1/auto_partition/sql/multi_thread_load.groovy
@@ -74,6 +74,18 @@ suite("multi_thread_load", "p1,nonConcurrent") { // stress
case should use resou
def sout = new StringBuilder(), serr = new StringBuilder()
proc.consumeProcessOutput(sout, serr)
proc.waitForOrKill(7200000)
+ logger.info("std out: " + sout + ", std err: " + serr)
+ }
+ for (int i = 0; i < data_count; i++) {
+ def dir_name = """${dirPath}/${part_type}/${part_type}_${i}"""
+ def directory = new File(dir_name)
+ assertTrue(directory.exists())
+ assertTrue(directory.isDirectory())
+
+ def files = directory.listFiles()
+ assertTrue(files.length == 1)
+ assertTrue(files[0].isFile())
+ logger.info("The file name is: +
${dirPath}/${part_type}/${part_type}_${i}/${files[0].name}")
}
}
diff --git
a/regression-test/suites/partition_p1/auto_partition/sql/stress_test_insert_into.groovy
b/regression-test/suites/partition_p1/auto_partition/sql/stress_test_insert_into.groovy
index d2ce87248e0..cace519c16c 100644
---
a/regression-test/suites/partition_p1/auto_partition/sql/stress_test_insert_into.groovy
+++
b/regression-test/suites/partition_p1/auto_partition/sql/stress_test_insert_into.groovy
@@ -93,6 +93,7 @@ suite("stress_test_insert_into") {
def sout = new StringBuilder(), serr = new StringBuilder()
proc.consumeProcessOutput(sout, serr)
proc.waitForOrKill(1800000)
+ logger.info("std out: " + sout + ", std err: " + serr)
}
def database_name = "regression_test_auto_partition_concurrent"
diff --git
a/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy
b/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy
index fc8df758c7c..fe536cd2469 100644
---
a/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy
+++
b/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy
@@ -78,7 +78,6 @@ suite("stress_test_diff_date_list", "p2,nonConcurrent") {
proc.consumeProcessOutput(sout, serr)
proc.waitForOrKill(7200000)
logger.info("std out: " + sout + "std err: " + serr)
-
}
def write_to_file = { cur_path, content ->
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
