This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 269873d44e0 [fix](regression-test) fix variant_p2 case to show load
failure #52652 (#52687)
269873d44e0 is described below
commit 269873d44e0a14842a344f03468cd8577bb9e904
Author: shuke <[email protected]>
AuthorDate: Mon Aug 18 11:01:09 2025 +0800
[fix](regression-test) fix variant_p2 case to show load failure #52652
(#52687)
---
regression-test/suites/variant_p2/load.groovy | 18 ++++++++++++++----
1 file changed, 14 insertions(+), 4 deletions(-)
diff --git a/regression-test/suites/variant_p2/load.groovy
b/regression-test/suites/variant_p2/load.groovy
index 056bb666e34..a15bc8b1128 100644
--- a/regression-test/suites/variant_p2/load.groovy
+++ b/regression-test/suites/variant_p2/load.groovy
@@ -74,6 +74,7 @@ suite("load_p2", "variant_type,p2"){
// Executor service for managing threads
def executorService = Executors.newFixedThreadPool(numberOfThreads)
+ def futures = []
try {
def table_name = "github_events"
@@ -141,16 +142,25 @@ suite("load_p2", "variant_type,p2"){
def fileName = year + "-" + month + "-" + day + "-" + hour
+ ".json"
log.info("cuurent fileName: ${fileName}")
// Submitting tasks to the executor service
- executorService.submit({
+ futures << executorService.submit({
log.info("Loading file: ${fileName}")
s3load_paral_wait.call(table_name, "JSON",
"regression/github_events_dataset/${fileName}", 3)
} as Runnable)
}
}
}
- // Shutdown executor service and wait for all tasks to complete
- executorService.shutdown()
- executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS)
+
+ try {
+ futures.each { future ->
+ future.get()
+ }
+ } catch (Exception e) {
+ throw e.cause // throw original exception
+ } finally {
+ // Shutdown executor service and wait for all tasks to complete
+ executorService.shutdown()
+ executorService.awaitTermination(Long.MAX_VALUE,
TimeUnit.NANOSECONDS)
+ }
qt_sql("select count() from github_events")
} finally {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
