This is an automated email from the ASF dual-hosted git repository.
airborne 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 25c251d0717 [test](inverted index) make
test_cumulative_compaction_with_format_v2 regression case more stable (#53756)
25c251d0717 is described below
commit 25c251d07174e58c547b6411f9cd5638fad4ce2e
Author: airborne12 <[email protected]>
AuthorDate: Wed Jul 23 14:31:41 2025 +0800
[test](inverted index) make test_cumulative_compaction_with_format_v2
regression case more stable (#53756)
---
...est_cumulative_compaction_with_format_v2.groovy | 31 +++++++++++++++++++++-
1 file changed, 30 insertions(+), 1 deletion(-)
diff --git
a/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
b/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
index eff05b1fd8d..6e39fa09fcd 100644
---
a/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
+++
b/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
@@ -163,13 +163,42 @@ suite("test_cumulative_compaction_with_format_v2",
"inverted_index_format_v2") {
def tablets = sql_return_maparray """ show tablets from ${tableName};
"""
// trigger compactions for all tablets in ${tableName}
- trigger_and_wait_compaction(tableName, "cumulative")
+ //trigger_and_wait_compaction(tableName, "cumulative")
// wait for all compactions done
for (def tablet in tablets) {
String tablet_id = tablet.TabletId
backend_id = tablet.BackendId
String ip = backendId_to_backendIP.get(backend_id)
String port = backendId_to_backendHttpPort.get(backend_id)
+ be_show_tablet_status(ip, port, tablet_id)
+ (code, out, err) = be_show_tablet_status(ip, port, tablet_id)
+ logger.info("Run show: code=" + code + ", out=" + out + ", err=" +
err)
+ assertTrue(out.contains("[0-1]"))
+ assertTrue(out.contains("[2-2]"))
+ assertTrue(out.contains("[3-3]"))
+ assertTrue(out.contains("[4-4]"))
+ assertTrue(out.contains("[5-5]"))
+ assertTrue(out.contains("[6-6]"))
+ assertTrue(out.contains("[7-7]"))
+ assertTrue(out.contains("[8-8]"))
+ assertTrue(out.contains("[9-9]"))
+ logger.info("run compaction:" + tablet_id)
+ (code, out, err) = be_run_cumulative_compaction(ip, port,
tablet_id)
+ logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
+ boolean running = true
+ do {
+ Thread.sleep(100)
+ (code, out, err) = be_get_compaction_status(ip, port,
tablet_id)
+ logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
+ assertEquals(code, 0)
+ def compactionStatus = parseJson(out.trim())
+ assertEquals("success", compactionStatus.status.toLowerCase())
+ running = compactionStatus.run_status
+ } while (running)
+ (code, out, err) = be_show_tablet_status(ip, port, tablet_id)
+ logger.info("Run show: code=" + code + ", out=" + out + ", err=" +
err)
+ assertTrue(out.contains("[0-1]"))
+ assertTrue(out.contains("[2-9]"))
int segment_count = calc_segment_count(tablet)
logger.info("TabletId: " + tablet_id + ", segment_count: " +
segment_count)
check_nested_index_file(ip, port, tablet_id, 2, 3, "V2")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
