Skip to content

Commit f530fcb

Browse files
branch-4.1: [fix](test) stabilize internal copy recycler case #63340 (#63601)
Cherry-picked from #63340 Co-authored-by: hui lai <laihui@selectdb.com>
1 parent da6ff4d commit f530fcb

1 file changed

Lines changed: 16 additions & 5 deletions

File tree

regression-test/suites/cloud_p0/recycler/test_recycler_with_internal_copy.groovy

Lines changed: 16 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -95,11 +95,22 @@ suite("test_recycler_with_internal_copy") {
9595
logger.info("Request FE Config: code=" + code + ", out=" + out + ", err=" + err)
9696
assertEquals(code, 0)
9797

98-
result = sql " copy into ${tableName} from @~('${fileName}') properties ('file.type' = 'csv', 'file.column_separator' = '|', 'copy.async' = 'false'); "
99-
logger.info("copy result: " + result)
100-
assertTrue(result.size() == 1)
101-
assertTrue(result[0].size() == 8)
102-
assertTrue(result[0][1].equals("FINISHED"), "Finish copy into, state=" + result[0][1] + ", expected state=FINISHED")
98+
retry = 15
99+
success = false
100+
do {
101+
result = sql " copy into ${tableName} from @~('${fileName}') properties ('file.type' = 'csv', 'file.column_separator' = '|', 'copy.async' = 'false'); "
102+
logger.info("copy result after recycle: " + result)
103+
assertTrue(result.size() == 1)
104+
assertTrue(result[0].size() == 8)
105+
if (result[0][1].equals("FINISHED")) {
106+
success = true
107+
break
108+
}
109+
assertTrue(result[0][1].equals("CANCELLED") && result[0][3].contains("No files can be copied"),
110+
"Finish copy into, state=" + result[0][1] + ", expected state=FINISHED")
111+
Thread.sleep(20000) // wait copy job metadata recycled
112+
} while (retry--)
113+
assertTrue(success)
103114
qt_sql " SELECT COUNT(*) FROM ${tableName}; "
104115

105116
String[][] tabletInfoList = sql """ show tablets from ${tableName}; """

0 commit comments

Comments
 (0)