This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 1db5b9a6dbf branch-3.1: [fix](test) fix unstable export test cases
#58442 (#58524)
1db5b9a6dbf is described below
commit 1db5b9a6dbf6e103efe22fe2b57d7c81229acb15
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Dec 2 11:06:21 2025 +0800
branch-3.1: [fix](test) fix unstable export test cases #58442 (#58524)
Cherry-picked from #58442
Co-authored-by: Mingyu Chen (Rayner) <[email protected]>
---
.../export/test_export_external_table.groovy | 30 +++++++++++++---------
1 file changed, 18 insertions(+), 12 deletions(-)
diff --git
a/regression-test/suites/external_table_p0/export/test_export_external_table.groovy
b/regression-test/suites/external_table_p0/export/test_export_external_table.groovy
index c76c71cd17d..179f5066b74 100644
---
a/regression-test/suites/external_table_p0/export/test_export_external_table.groovy
+++
b/regression-test/suites/external_table_p0/export/test_export_external_table.groovy
@@ -156,6 +156,10 @@ suite("test_export_external_table",
"p0,external,mysql,external_docker,external_
"""
waiting_export.call(catalog_name, ex_db_name, label)
+ def export_res = sql """show export where label='${label}'"""
+ logger.info("get export res ${export_res}")
+ def outfileinfo = export_res[0][11];
+ logger.info("get export outfile info ${outfileinfo}")
// check data correctness
create_load_table(table_load_name)
@@ -164,18 +168,20 @@ suite("test_export_external_table",
"p0,external,mysql,external_docker,external_
def portList = [:]
getBackendIpHeartbeatPort(ipList, portList)
ipList.each { beid, ip ->
- logger.info("Begin to insert into
internal.${internal_db_name}.${table_load_name} from local()")
- sql """
- insert into
internal.${internal_db_name}.${table_load_name}
- select * from local(
- "file_path" =
"${local_tvf_prefix}/${table_export_name}_${uuid}/*",
- "backend_id" = "${beid}",
- "format" = "csv",
- "column_separator" = ","
- );
- """
- def insert_res = sql "show last insert;"
- logger.info("insert from local(), BE id = ${beid}, result: " +
insert_res.toString())
+ if (outfileinfo.contains(ip)) {
+ logger.info("Begin to insert into
internal.${internal_db_name}.${table_load_name} from local()")
+ sql """
+ insert into
internal.${internal_db_name}.${table_load_name}
+ select * from local(
+ "file_path" =
"${local_tvf_prefix}/${table_export_name}_${uuid}/*",
+ "backend_id" = "${beid}",
+ "format" = "csv",
+ "column_separator" = ","
+ );
+ """
+ def insert_res = sql "show last insert;"
+ logger.info("insert from local(), BE id = ${beid}, result:
" + insert_res.toString())
+ }
}
order_qt_select_load1 """ SELECT * FROM
internal.${internal_db_name}.${table_load_name} order by k8; """
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
