This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 887a719c66c branch-4.0: [fix](test) stabilize internal copy recycler
case #63340 (#63599)
887a719c66c is described below
commit 887a719c66c0fe2d4e4c39fcc8da434414b21187
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jun 9 10:02:57 2026 +0800
branch-4.0: [fix](test) stabilize internal copy recycler case #63340
(#63599)
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]
