This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new f530fcbfc7a branch-4.1: [fix](test) stabilize internal copy recycler
case #63340 (#63601)
f530fcbfc7a is described below
commit f530fcbfc7ad3e97691dfc3321fcb3aee104b245
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue May 26 12:20:39 2026 +0800
branch-4.1: [fix](test) stabilize internal copy recycler case #63340
(#63601)
Cherry-picked from #63340
Co-authored-by: hui lai <[email protected]>
---
.../test_recycler_with_internal_copy.groovy | 21 ++++++++++++++++-----
1 file changed, 16 insertions(+), 5 deletions(-)
diff --git
a/regression-test/suites/cloud_p0/recycler/test_recycler_with_internal_copy.groovy
b/regression-test/suites/cloud_p0/recycler/test_recycler_with_internal_copy.groovy
index eb1c408d3c6..ae7834f7e23 100644
---
a/regression-test/suites/cloud_p0/recycler/test_recycler_with_internal_copy.groovy
+++
b/regression-test/suites/cloud_p0/recycler/test_recycler_with_internal_copy.groovy
@@ -95,11 +95,22 @@ suite("test_recycler_with_internal_copy") {
logger.info("Request FE Config: code=" + code + ", out=" + out + ", err="
+ err)
assertEquals(code, 0)
- result = sql " copy into ${tableName} from @~('${fileName}') properties
('file.type' = 'csv', 'file.column_separator' = '|', 'copy.async' = 'false'); "
- logger.info("copy result: " + result)
- assertTrue(result.size() == 1)
- assertTrue(result[0].size() == 8)
- assertTrue(result[0][1].equals("FINISHED"), "Finish copy into, state=" +
result[0][1] + ", expected state=FINISHED")
+ retry = 15
+ success = false
+ do {
+ result = sql " copy into ${tableName} from @~('${fileName}')
properties ('file.type' = 'csv', 'file.column_separator' = '|', 'copy.async' =
'false'); "
+ logger.info("copy result after recycle: " + result)
+ assertTrue(result.size() == 1)
+ assertTrue(result[0].size() == 8)
+ if (result[0][1].equals("FINISHED")) {
+ success = true
+ break
+ }
+ assertTrue(result[0][1].equals("CANCELLED") &&
result[0][3].contains("No files can be copied"),
+ "Finish copy into, state=" + result[0][1] + ", expected
state=FINISHED")
+ Thread.sleep(20000) // wait copy job metadata recycled
+ } while (retry--)
+ assertTrue(success)
qt_sql " SELECT COUNT(*) FROM ${tableName}; "
String[][] tabletInfoList = sql """ show tablets from ${tableName}; """
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
