This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new fe87a09ee60 [Fix](case) Fix case
`test_key_bounds_truncation_write_scenarios` (#51761)
fe87a09ee60 is described below
commit fe87a09ee60a7d740fd093e4e4ac4bb5c30ace39
Author: bobhan1 <[email protected]>
AuthorDate: Tue Jun 17 13:51:37 2025 +0800
[Fix](case) Fix case `test_key_bounds_truncation_write_scenarios` (#51761)
case should trigger full compaction on all BEs
---
...st_key_bounds_truncation_write_scenarios.groovy | 36 +---------------------
1 file changed, 1 insertion(+), 35 deletions(-)
diff --git
a/regression-test/suites/unique_with_mow_p0/key_bounds/test_key_bounds_truncation_write_scenarios.groovy
b/regression-test/suites/unique_with_mow_p0/key_bounds/test_key_bounds_truncation_write_scenarios.groovy
index bbb479a7bd3..27dc9c32aa7 100644
---
a/regression-test/suites/unique_with_mow_p0/key_bounds/test_key_bounds_truncation_write_scenarios.groovy
+++
b/regression-test/suites/unique_with_mow_p0/key_bounds/test_key_bounds_truncation_write_scenarios.groovy
@@ -242,41 +242,7 @@ suite("test_key_bounds_truncation_write_scenarios",
"nonConcurrent") {
logger.info("============= compaction ==============")
set_be_param("segments_key_bounds_truncation_threshold", 8)
Thread.sleep(2000)
- def triggerFullCompaction = {
- def beNodes = sql_return_maparray("show backends;")
- def tabletStat = sql_return_maparray("show tablets from
${tableName};").get(0)
- def tabletBackendId = tabletStat.BackendId
- def tabletId = tabletStat.TabletId
- def tabletBackend;
- for (def be : beNodes) {
- if (be.BackendId == tabletBackendId) {
- tabletBackend = be
- break;
- }
- }
-
- logger.info("trigger compaction on another BE
${tabletBackend.Host} with backendId=${tabletBackend.BackendId}")
- def (code, out, err) = be_run_full_compaction(tabletBackend.Host,
tabletBackend.HttpPort, tabletId)
- logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
- assertEquals(code, 0)
- def compactJson = parseJson(out.trim())
- assertEquals("success", compactJson.status.toLowerCase())
-
- // wait for full compaction to complete
- Awaitility.await().atMost(3, TimeUnit.SECONDS).pollDelay(200,
TimeUnit.MILLISECONDS).pollInterval(100, TimeUnit.MILLISECONDS).until(
- {
- (code, out, err) =
be_get_compaction_status(tabletBackend.Host, tabletBackend.HttpPort, tabletId)
- logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
- assertEquals(code, 0)
- def compactionStatus = parseJson(out.trim())
- assertEquals("success",
compactionStatus.status.toLowerCase())
- return !compactionStatus.run_status
- }
- )
- }
-
- // trigger full compaction on tablet
- triggerFullCompaction()
+ trigger_and_wait_compaction(tableName, "full")
checkKeyBounds(8)
qt_sql "select count(*) from ${tableName};"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
