database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](regression-test) fix variant_p2 case to show load failure #52652 (#52686)

Browse Source
This commit is contained in:
shuke
2025-07-03 08:27:35 +08:00
committed by GitHub
parent ea8ef605a6
commit cf3fe579ad
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
regression-test/suites/variant_p2/load.groovy
View File

@ -85,6 +85,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"
@ -152,16 +153,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 {